-
Notifications
You must be signed in to change notification settings - Fork 43
Open
Description
Hey!
I am having some trouble with tokio::sync::oneshot
sender being passed through kanal. The receiver never receives data back. But if I use tokio::sync::mpsc
instead of kanal::bounded
it works. Here's my code:
let Signal(data, ip) = receiver.recv().expect("analyzer recv failed");
SignalData::Debug(debug) => {
println!("{:#?}", debug.send(format!("{:#?}", me)));
}
let (sender, receiver) = tokio::sync::oneshot::channel(); // but works with kanal::bounded(0)
send_signal(Signal(SignalData::Debug(sender), addr.into()));
let w = receiver.await.expect("receiver hanged up"); // future never completes.
Response::builder().body(body(w))
Metadata
Metadata
Assignees
Labels
No labels