hermes_runtime_components::traits::stream

Trait StreamMapper

Source 
pub trait StreamMapper<Runtime>
where
    Runtime: HasStreamType,
{
    // Required method
    fn map_stream<T, U, M>(
        stream: Runtime::Stream<T>,
        mapper: M,
    ) -> Runtime::Stream<U>
       where T: Async,
             U: Async,
             M: Fn(T) -> U + Async;
}

Required Methods§

Source

fn map_stream<T, U, M>( stream: Runtime::Stream<T>, mapper: M, ) -> Runtime::Stream<U>
where T: Async, U: Async, M: Fn(T) -> U + Async,

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§

Source§

impl<Component, Runtime> StreamMapper<Runtime> for Component
where Runtime: HasStreamType, Component: DelegateComponent<StreamMapperComponent>, Component::Delegate: StreamMapper<Runtime>,