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 32fa0dd commit 146a6f5Copy full SHA for 146a6f5
1 file changed
implementations/rust/ockam/ockam_node/src/context.rs
@@ -82,8 +82,7 @@ impl Context {
82
let (reply_tx, mut reply_rx) = channel(1);
83
let req = NodeMessage::SenderReq(address, reply_tx);
84
85
- // FIXME/ DESIGN: error communication concept
86
- let _result: Result<()> = match self.sender.send(req).await {
+ match self.sender.send(req).await {
87
Ok(()) => {
88
if let Some(NodeReply::Sender(_, s)) = reply_rx.recv().await {
89
let msg = msg.encode().unwrap();
@@ -96,9 +95,7 @@ impl Context {
96
95
}
97
98
Err(_e) => Err(Error::FailedSendMessage.into()),
99
- };
100
-
101
- Ok(())
+ }
102
103
104
/// Block the current worker to wait for a typed message
0 commit comments