aljaz/sphinx-key
1
1
Fork 0
mirror of https://github.com/stakwork/sphinx-key.git synced 2026-02-18 14:14:41 +01:00
Code Issues Packages Projects Releases Wiki Activity

copy SignerPort get_reply from vls

Browse Source
This commit is contained in:
Evan Feenstra
2022-06-27 17:15:26 -07:00
parent 2f92844e62
commit e936d6784a
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
broker/src/unix_fd.rs
View File

@@ -1,11 +1,11 @@
use crate::{Channel, ChannelReply, ChannelRequest};
use async_trait::async_trait;
use log::*;
use secp256k1::PublicKey;
use sphinx_key_parser as parser;
use std::thread;
use tokio::sync::{mpsc, oneshot};
// use tokio::task::spawn_blocking;
use crate::{Channel, ChannelReply, ChannelRequest};
use async_trait::async_trait;
use tokio::task::spawn_blocking;
use vls_protocol::{msgs, msgs::Message, Error, Result};
use vls_protocol_client::SignerPort;
use vls_proxy::client::Client;
@@ -166,7 +166,10 @@ impl MqttSignerPort {
}
async fn get_reply(&self, reply_rx: oneshot::Receiver<ChannelReply>) -> Result<Vec<u8>> {
let reply = reply_rx.blocking_recv().map_err(|_| Error::Eof)?;
let reply = spawn_blocking(move || reply_rx.blocking_recv())
.await
.map_err(|_| Error::Eof)?
.map_err(|_| Error::Eof)?;
Ok(reply.reply)
}
}