Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
  • Loading branch information
jeromegn committed Oct 23, 2022
1 parent fcbef50 commit ece7d55
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion src/proto/streams/stream.rs
Expand Up @@ -322,7 +322,9 @@ impl Stream {
}

pub fn wait_send(&mut self, cx: &Context) {
self.send_task = Some(cx.waker().clone());
if let Some(task) = self.send_task.take() {
task.wake();
}
}

pub fn notify_recv(&mut self) {
Expand Down

0 comments on commit ece7d55

Please sign in to comment.