Trait StreamTypes

pub trait StreamTypes: ConnectionErrors {
    type In: RpcMessage;
    type Out: RpcMessage;
    type RecvStream: Stream<Item = Result<Self::In, Self::RecvError>> + Send + Sync + Unpin + 'static;
    type SendSink: Sink<Self::Out, Error = Self::SendError> + Send + Sync + Unpin + 'static;
}

Types that are common to both Connector and Listener.

Having this as a separate trait is useful when writing generic code that works with both.

Required Associated Types

type In: RpcMessage

The type of messages that can be received on the channel

type Out: RpcMessage

The type of messages that can be sent on the channel

type RecvStream: Stream<Item = Result<Self::In, Self::RecvError>> + Send + Sync + Unpin + 'static

Receive side of a bidirectional typed channel

type SendSink: Sink<Self::Out, Error = Self::SendError> + Send + Sync + Unpin + 'static

Send side of a bidirectional typed channel

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl<A: Connector, B: Connector<In = A::In, Out = A::Out>> StreamTypes for CombinedConnector<A, B>

type In = <A as StreamTypes>::In

type Out = <A as StreamTypes>::Out

type RecvStream = RecvStream<A, B>

type SendSink = SendSink<A, B>

impl<A: Listener, B: Listener<In = A::In, Out = A::Out>> StreamTypes for CombinedListener<A, B>

type In = <A as StreamTypes>::In

type Out = <A as StreamTypes>::Out

type RecvStream = RecvStream<A, B>

type SendSink = SendSink<A, B>

impl<In, Out, C> StreamTypes for MappedConnector<In, Out, C>

where C: StreamTypes, In: RpcMessage + TryFrom<C::In>, Out: RpcMessage, C::Out: From<Out>,

type In = In

type Out = Out

type RecvStream = MappedRecvStream<<C as StreamTypes>::RecvStream, In>

type SendSink = MappedSendSink<<C as StreamTypes>::SendSink, Out, <C as StreamTypes>::Out>

impl<In, Out, C> StreamTypes for MappedStreamTypes<In, Out, C>

where C: StreamTypes, In: RpcMessage + TryFrom<C::In>, Out: RpcMessage, C::Out: From<Out>,

type In = In

type Out = Out

type RecvStream = MappedRecvStream<<C as StreamTypes>::RecvStream, In>

type SendSink = MappedSendSink<<C as StreamTypes>::SendSink, Out, <C as StreamTypes>::Out>

impl<In: RpcMessage, Out: RpcMessage> StreamTypes for BoxedConnector<In, Out>

type In = In

type Out = Out

type RecvStream = RecvStream<In>

type SendSink = SendSink<Out>

impl<In: RpcMessage, Out: RpcMessage> StreamTypes for BoxedListener<In, Out>

type In = In

type Out = Out

type RecvStream = RecvStream<In>

type SendSink = SendSink<Out>

impl<In: RpcMessage, Out: RpcMessage> StreamTypes for BoxedStreamTypes<In, Out>

type In = In

type Out = Out

type RecvStream = RecvStream<In>

type SendSink = SendSink<Out>

impl<In: RpcMessage, Out: RpcMessage> StreamTypes for FlumeConnector<In, Out>

Available on crate feature flume-transport only.

type In = In

type Out = Out

type SendSink = SendSink<Out>

type RecvStream = RecvStream<In>

impl<In: RpcMessage, Out: RpcMessage> StreamTypes for FlumeListener<In, Out>

Available on crate feature flume-transport only.

type In = In

type Out = Out

type SendSink = SendSink<Out>

type RecvStream = RecvStream<In>

impl<In: RpcMessage, Out: RpcMessage> StreamTypes for HyperConnector<In, Out>

Available on crate feature hyper-transport only.

type In = In

type Out = Out

type RecvStream = RecvStream<In>

type SendSink = SendSink<Out>

impl<In: RpcMessage, Out: RpcMessage> StreamTypes for HyperListener<In, Out>

Available on crate feature hyper-transport only.

type In = In

type Out = Out

type RecvStream = RecvStream<In>

type SendSink = SendSink<Out>

impl<In: RpcMessage, Out: RpcMessage> StreamTypes for IrohConnector<In, Out>

Available on crate feature iroh-transport only.

type In = In

type Out = Out

type SendSink = SendSink<Out>

type RecvStream = RecvStream<In>

impl<In: RpcMessage, Out: RpcMessage> StreamTypes for IrohListener<In, Out>

Available on crate feature iroh-transport only.

type In = In

type Out = Out

type SendSink = SendSink<Out>

type RecvStream = RecvStream<In>

impl<In: RpcMessage, Out: RpcMessage> StreamTypes for DummyListener<In, Out>

type In = In

type Out = Out

type RecvStream = Pending<Result<In, <DummyListener<In, Out> as ConnectionErrors>::RecvError>>

type SendSink = Box<dyn Sink<Out, Error = <DummyListener<In, Out> as ConnectionErrors>::SendError> + Unpin + Send + Sync>

impl<In: RpcMessage, Out: RpcMessage> StreamTypes for QuinnConnector<In, Out>

Available on crate feature quinn-transport only.

type In = In

type Out = Out

type SendSink = SendSink<Out>

type RecvStream = RecvStream<In>

impl<In: RpcMessage, Out: RpcMessage> StreamTypes for QuinnListener<In, Out>

Available on crate feature quinn-transport only.

type In = In

type Out = Out

type SendSink = SendSink<Out>

type RecvStream = RecvStream<In>