File tree 3 files changed +8
-8
lines changed
3 files changed +8
-8
lines changed Original file line number Diff line number Diff line change @@ -38,15 +38,15 @@ pub trait Stream {
38
38
/// stream state:
39
39
///
40
40
/// - `Poll::Pending` means that this stream's next value is not ready
41
- /// yet. Implementations will ensure that the current task will be notified
42
- /// when the next value may be ready.
41
+ /// yet. Implementations will ensure that the current task will be notified
42
+ /// when the next value may be ready.
43
43
///
44
44
/// - `Poll::Ready(Some(val))` means that the stream has successfully
45
- /// produced a value, `val`, and may produce further values on subsequent
46
- /// `poll_next` calls.
45
+ /// produced a value, `val`, and may produce further values on subsequent
46
+ /// `poll_next` calls.
47
47
///
48
48
/// - `Poll::Ready(None)` means that the stream has terminated, and
49
- /// `poll_next` should not be invoked again.
49
+ /// `poll_next` should not be invoked again.
50
50
///
51
51
/// # Panics
52
52
///
Original file line number Diff line number Diff line change @@ -64,7 +64,7 @@ impl<T> Abortable<T> {
64
64
/// This means that it will return `true` even if:
65
65
/// * `abort` was called after the task had completed.
66
66
/// * `abort` was called while the task was being polled - the task may still be running and
67
- /// will not be stopped until `poll` returns.
67
+ /// will not be stopped until `poll` returns.
68
68
pub fn is_aborted ( & self ) -> bool {
69
69
self . inner . aborted . load ( Ordering :: Relaxed )
70
70
}
@@ -200,7 +200,7 @@ impl AbortHandle {
200
200
/// even if:
201
201
/// * `abort` was called after the task had completed.
202
202
/// * `abort` was called while the task was being polled - the task may still be running and
203
- /// will not be stopped until `poll` returns.
203
+ /// will not be stopped until `poll` returns.
204
204
///
205
205
/// This operation has a Relaxed ordering.
206
206
pub fn is_aborted ( & self ) -> bool {
Original file line number Diff line number Diff line change @@ -119,7 +119,7 @@ impl SharedPollState {
119
119
/// - `!WAKING` as
120
120
/// * Wakers called during the `POLLING` phase won't propagate their calls
121
121
/// * `POLLING` phase can't start if some of the wakers are active
122
- /// So no wrapped waker can touch the inner waker's cell, it's safe to poll again.
122
+ /// So no wrapped waker can touch the inner waker's cell, it's safe to poll again.
123
123
fn stop_polling ( & self , to_poll : u8 , will_be_woken : bool ) -> u8 {
124
124
self . state
125
125
. fetch_update ( Ordering :: SeqCst , Ordering :: SeqCst , |mut value| {
You can’t perform that action at this time.
0 commit comments