Trait gloo_worker::reactor::ReactorScoped

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;
}

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

Required Associated Types

type Input

The Input Message.

type Output

The Output Message.

Required Methods

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.

Implementors

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

type Input = I

type Output = O