Trait Stream

pub trait Stream<Request> {
    type Response;
    type Function: Future<Output = Self::Response>;

    // Required method
    fn next(&self, request: Request) -> Self::Function;
}

Required Associated Types

type Response

type Function: Future<Output = Self::Response>

Required Methods

fn next(&self, request: Request) -> Self::Function

Implementors

impl<T, Function> Stream<()> for T

where T: Fn() -> Function, Function: Future,

type Response = <Function as Future>::Output

type Function = Function

impl<T, Function, Arg1> Stream<(Arg1,)> for T

where T: Fn(Arg1) -> Function, Function: Future,

type Response = <Function as Future>::Output

type Function = Function

impl<T, Function, Arg1, Arg2> Stream<(Arg1, Arg2)> for T

where T: Fn(Arg1, Arg2) -> Function, Function: Future,

type Response = <Function as Future>::Output

type Function = Function

impl<T, Function, Arg1, Arg2, Arg3> Stream<(Arg1, Arg2, Arg3)> for T

where T: Fn(Arg1, Arg2, Arg3) -> Function, Function: Future,

type Response = <Function as Future>::Output

type Function = Function