Page MenuHomePhabricator
Files F3245142

D6284.id22625.diff
No OneTemporary
Actions

D6284.id22625.diff
View Options

diff --git a/shared/tunnelbroker-client/src/lib.rs b/shared/tunnelbroker-client/src/lib.rs
--- a/shared/tunnelbroker-client/src/lib.rs
+++ b/shared/tunnelbroker-client/src/lib.rs
@@ -1,6 +1,8 @@
+use anyhow::Result;
use lazy_static::lazy_static;
use std::sync::Arc;
use tokio::runtime::{Builder, Runtime};
+use tokio::sync::mpsc;
use tonic::transport::Channel;
pub mod tunnelbroker_pb {
@@ -24,3 +26,18 @@
.block_on(TunnelbrokerServiceClient::connect(addr))
.expect("Failed to connect to the Tunnelbroker Service")
}
+
+pub async fn publish_messages(
+ tx: &mpsc::Sender<tunnelbroker_pb::MessageToTunnelbroker>,
+ messages: Vec<tunnelbroker_pb::MessageToTunnelbrokerStruct>,
+) -> Result<()> {
+ let messages = tunnelbroker_pb::MessageToTunnelbroker {
+ data: Some(
+ tunnelbroker_pb::message_to_tunnelbroker::Data::MessagesToSend(
+ tunnelbroker_pb::MessagesToSend { messages },
+ ),
+ ),
+ };
+ tx.send(messages).await?;
+ Ok(())
+}

File Metadata

Mime Type
text/plain
Expires
Fri, Nov 15, 4:43 PM (1 h, 20 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2494841
Default Alt Text
D6284.id22625.diff (983 B)

Event Timeline