Struct Channel 

pub struct Channel {
    pub rx: UnboundedReceiver<Result<Message, Error>>,
    pub tx: UnboundedSender<Result<Message, Error>>,
}

A channel endpoint representing one side of a bidirectional message channel.

Channel represents a single endpoint’s view of a bidirectional communication channel. Each endpoint has:

• rx: A receiver for incoming messages (or errors) from the counterpart
• tx: A sender for outgoing messages (or errors) to the counterpart

Example

// Create a pair of connected channels
let (channel_a, channel_b) = Channel::duplex();

// Each channel can be used by a different component
UntypedLink::builder()
    .name("connection-a")
    .serve(channel_a)
    .await?;

Fields

rx: UnboundedReceiver<Result<Message, Error>>

Receives messages (or errors) from the counterpart.

tx: UnboundedSender<Result<Message, Error>>

Sends messages (or errors) to the counterpart.

Implementations

impl Channel

pub fn duplex() -> (Self, Self)

Create a pair of connected channel endpoints.

Returns two Channel instances that are connected to each other:

• Messages sent via channel_a.tx are received on channel_b.rx
• Messages sent via channel_b.tx are received on channel_a.rx

Returns

A tuple (channel_a, channel_b) of connected channel endpoints.

pub async fn copy(self) -> Result<(), Error>

Copy messages from rx to tx.

Returns

A Result indicating success or failure.

Trait Implementations

impl<L: JrLink> Component<L> for Channel

async fn serve(self, client: impl Component<L::ConnectsTo>) -> Result<(), Error>

Serve this component by forwarding to a client component.

fn into_server(self) -> (Channel, BoxFuture<'static, Result<(), Error>>)

Convert this component into a channel endpoint and server future.