Trait ResolverOutput

pub trait ResolverOutput<TError>:
    Sized
    + Send
    + 'static {
    type T;

    // Required methods
    fn data_type(types: &mut TypeCollection) -> DataType;
    fn into_stream(
        self,
    ) -> impl Stream<Item = Result<Self::T, ProcedureError>> + Send + 'static;
    fn into_procedure_stream(
        stream: impl Stream<Item = Result<Self::T, ProcedureError>> + Send + 'static,
    ) -> ProcedureStream;
}

TODO: bring back any correct parts of the docs above

Required Associated Types

type T

Required Methods

fn data_type(types: &mut TypeCollection) -> DataType

fn into_stream( self, ) -> impl Stream<Item = Result<Self::T, ProcedureError>> + Send + 'static

Convert the procedure into a Stream.

fn into_procedure_stream( stream: impl Stream<Item = Result<Self::T, ProcedureError>> + Send + 'static, ) -> ProcedureStream

Convert the stream into a ProcedureStream.

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

impl<T, E> ResolverOutput<E> for T

where T: Serialize + Type + Send + Sync + 'static, E: Error,

type T = T

impl<TErr, S, T> ResolverOutput<TErr> for Stream<S>

where TErr: Error, S: Stream<Item = Result<T, TErr>> + Send + 'static, T: ResolverOutput<TErr>,

type T = <T as ResolverOutput<TErr>>::T