Type Definition vessels::kind::Stream

type Stream<T> = Pin<Box<dyn IStream<Item = T> + Sync + Send>>;

Trait Implementations

impl<U: From<TransportError>, T> Flatten for Stream<Result<T, U>>

fn flatten<E: 'static + Sync + Send + Into<Error>, F: IFuture<Output = Result<Self, E>> + Sync + Send + 'static>(
    fut: F
) -> Self

impl<T> Kind for Stream<T> where
    T: Kind, 

type ConstructItem = Option<ForkHandle>

The item transmitted over the network to the construction task from deconstruction.

type ConstructError = WrappedError<T::ConstructError>

The failure condition of constructing a concrete type from communicated data.

type ConstructFuture = Future<ConstructResult<Self>>

The concrete future type returned by the construction process.

type DeconstructItem = ()

The item transmitted over the network from the construction task to deconstruction.

type DeconstructError = WrappedError<T::DeconstructError>

The failure condition of constructing a concrete type from communicated data.

type DeconstructFuture = Future<DeconstructResult<Self>>

The concrete future type returned by the deconstruction process. This is used to only to communicate failure of deconstruction and does not return a value.

fn deconstruct<C: Channel<Self::DeconstructItem, Self::ConstructItem>>(
    self,
    channel: C
) -> Self::DeconstructFuture

Moves out of the Kind and deconstructs on to the provided channel. As with construct, this method should return immediately.

fn construct<C: Channel<Self::ConstructItem, Self::DeconstructItem>>(
    channel: C
) -> Self::ConstructFuture

Constructs the Kind from the provided channel. This method should return immediately and, if necessary, move channel into some shim structure, async block, or other owned state specified by ConstructFuture.

const USE_KIND_MACRO_TO_GENERATE_THIS_FIELD: [u8; 32]