Trait StreamCallback

pub trait StreamCallback<A> {
    // Required method
    fn invoke(
        &self,
        stream: Stream,
        args: A,
    ) -> Pin<Box<dyn Future<Output = ()> + Send>>;
}

Required Methods

fn invoke( &self, stream: Stream, args: A, ) -> Pin<Box<dyn Future<Output = ()> + Send>>

Implementors

impl<K, R> StreamCallback<()> for K

where K: Fn(Stream) -> R, R: Future<Output = ()> + Send + 'static,

impl<K, R, A> StreamCallback<(A,)> for K

where K: Fn(Stream, A) -> R, R: Future<Output = ()> + Send + 'static,

impl<K, R, A, B> StreamCallback<(A, B)> for K

where K: Fn(Stream, A, B) -> R, R: Future<Output = ()> + Send + 'static,

impl<K, R, A, B, C> StreamCallback<(A, B, C)> for K

where K: Fn(Stream, A, B, C) -> R, R: Future<Output = ()> + Send + 'static,

impl<K, R, A, B, C, D> StreamCallback<(A, B, C, D)> for K

where K: Fn(Stream, A, B, C, D) -> R, R: Future<Output = ()> + Send + 'static,

impl<K, R, A, B, C, D, E> StreamCallback<(A, B, C, D, E)> for K

where K: Fn(Stream, A, B, C, D, E) -> R, R: Future<Output = ()> + Send + 'static,