We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9435a9d commit 5dc935eCopy full SHA for 5dc935e
src/node.rs
@@ -376,7 +376,7 @@ impl<S: Send + 'static> NodeListener<S> {
376
/// handler.signals().send_with_timer((), std::time::Duration::from_secs(1));
377
/// let (id, addr) = handler.network().listen(Transport::FramedTcp, "127.0.0.1:0").unwrap();
378
///
379
- /// let task = listener.for_each(move |event| match event {
+ /// let task = listener.for_each_async(move |event| match event {
380
/// NodeEvent::Network(net_event) => { /* Your logic here */ },
381
/// NodeEvent::Signal(_) => handler.stop(),
382
/// });
0 commit comments