Struct ockam::channel::ChannelBuilder

pub struct ChannelBuilder { /* private fields */ }

Generalised ockam channel API

Implementations

impl ChannelBuilder

pub async fn new(ctx: &Context) -> Result<Self>

Create a new Ockam channel context

let builder = ChannelBuilder::new(ctx).await?;

// Create a new channel listener
builder.create_channel_listener("my-channel-listener").await?;

// Connect a channel to the listener
let ch = builder.connect(vec!["my-channel-listener"]).await?;
ctx.send(ch.tx().append("app"), String::from("Hello via channel!")).await?;

// Wait for the reply message
let msg = ctx.receive::<String>().await?;
println!("Received message '{}'", msg);

pub fn attach_tx_behavior<B: BehaviorHook + Clone + Send + Sync + 'static>(
    self,
    bev: B
) -> Self

Attach a new behavior to be used by the underlying pipe sender

pub fn attach_rx_behavior<B: BehaviorHook + Clone + Send + Sync + 'static>(
    self,
    bev: B
) -> Self

Attach a new behavior to be used by the underlying pipe receiver

pub async fn connect<R: Into<Route>>(
    &self,
    listener: R
) -> Result<ChannelHandle>

Connect to a channel listener

pub async fn create_channel_listener<A: Into<Address>>(
    &self,
    addr: A
) -> Result<()>

Create a new channel listener