[−][src]Trait actix_interop::StreamInterop

pub trait StreamInterop<A: Actor>: Stream + Sized {
    fn interop_actor(self, actor: &A) -> StreamInteropWrap<A, Self>;

    fn interop_actor_boxed(
        self, 
        actor: &A
    ) -> Box<dyn ActorStream<Item = Self::Item, Actor = A>>
    where
        Self: 'static,
    { ... }
}

Extension trait implemented for all streams. Import this trait to bring the interop_actor and interop_actor_boxed methods into scope.

Required methods

fn interop_actor(self, actor: &A) -> StreamInteropWrap<A, Self>

Convert a stream using the with_ctx or critical_section methods into an ActorStream.

Loading content...

Provided methods

fn interop_actor_boxed(
    self,
    actor: &A
) -> Box<dyn ActorStream<Item = Self::Item, Actor = A>> where
    Self: 'static, 

Convert a stream using the with_ctx or critical_section methods into a boxed ActorStream.

Loading content...

Implementors

impl<A: Actor, S: Stream> StreamInterop<A> for S[src]

Loading content...