File tree 1 file changed +4
-4
lines changed
1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -3,7 +3,7 @@ use std::sync::atomic::{AtomicBool, Ordering};
3
3
use std:: sync:: Arc ;
4
4
use tokio:: sync:: Notify ;
5
5
6
- /// Signaler returned as part of `NotifyOnEos::new` that can be polled to receive information,
6
+ /// Signaler returned as part of [ `NotifyOnEos::new`] that can be polled to receive information,
7
7
/// when the buffer gets advanced to the end.
8
8
// Cannot be Clone due to usage of `Notify::notify_one` in `NotifyOnEos::advance`,
9
9
// revisit once `Notify::notify_all` stabilizes.
@@ -17,11 +17,11 @@ impl EosSignaler {
17
17
}
18
18
}
19
19
20
- /// Wrapper for `bytes:: Buf` that returns a `EosSignaler` that can be polled to receive information,
20
+ /// Wrapper for [` Buf`] that returns an [ `EosSignaler`] that can be polled to receive information,
21
21
/// when the buffer gets advanced to the end.
22
22
///
23
- /// NOTE: For the notification to work, caller must ensure that `Buf::advance` gets called
24
- /// enough times to advance to the end of the buffer (so that `Buf::has_remaining` afterwards returns `0`).
23
+ /// NOTE: For the notification to work, caller must ensure that [ `Buf::advance`] gets called
24
+ /// enough times to advance to the end of the buffer (so that [ `Buf::has_remaining`] afterwards returns `0`).
25
25
pub struct NotifyOnEos < B > {
26
26
inner : B ,
27
27
notifier : Arc < Notify > ,
You can’t perform that action at this time.
0 commit comments