pub trait ReactorScoped: Stream + FusedStream {
    type Input;
    type Output;

    // Required method
    fn new<IS, OS>(input_stream: IS, output_sink: OS) -> Self
       where IS: Stream<Item = Self::Input> + FusedStream + 'static,
             OS: Sink<Self::Output, Error = Infallible> + 'static;
}
Expand description

A helper trait to extract the input and output type from a [ReactorStream].

Required Associated Types§

source

type Input

The Input Message.

source

type Output

The Output Message.

Required Methods§

source

fn new<IS, OS>(input_stream: IS, output_sink: OS) -> Selfwhere IS: Stream<Item = Self::Input> + FusedStream + 'static, OS: Sink<Self::Output, Error = Infallible> + 'static,

Creates a ReactorReceiver.

Object Safety§

This trait is not object safe.

Implementors§

source§

impl<I, O> ReactorScoped for ReactorScope<I, O>

§

type Input = I

§

type Output = O