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>

type In = In

type Out = Out

type SendSink = SendSink<Out>

type RecvStream = RecvStream<In>

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

type In = In

type Out = Out

type SendSink = SendSink<Out>

type RecvStream = RecvStream<In>

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

type In = In

type Out = Out

type RecvStream = RecvStream<In>

type SendSink = SendSink<Out>

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

type In = In

type Out = Out

type RecvStream = RecvStream<In>

type SendSink = SendSink<Out>

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

type In = In

type Out = Out

type SendSink = SendSink<Out>

type RecvStream = RecvStream<In>

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

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> + Sync + Send + Unpin>

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

type In = In

type Out = Out

type SendSink = SendSink<Out>

type RecvStream = RecvStream<In>

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

type In = In

type Out = Out

type SendSink = SendSink<Out>

type RecvStream = RecvStream<In>