Struct reactive_mutiny::uni::UniBuilder

pub struct UniBuilder<InType: 'static + Debug + Sync + Send, UniChannelType: FullDuplexUniChannel<'static, InType, DerivedItemType> + Sync + Send + 'static, const INSTRUMENTS: usize, DerivedItemType: 'static + Debug + Sync + Send> {
    pub concurrency_limit: u32,
    pub futures_timeout: Duration,
    pub instruments: Instruments,
    /* private fields */
}

Fields

concurrency_limit: u32

futures_timeout: Duration

if Some, will cause the pipeline to be wrapped with tokio::time::timeout so that an Err will be produced whenever the pipeline takes too much time to process

instruments: Instruments

Instrumentation this instance gathers / produces

Implementations

impl<InType: 'static + Sync + Send + Debug, UniChannelType: FullDuplexUniChannel<'static, InType, DerivedItemType> + Sync + Send + 'static, const INSTRUMENTS: usize, DerivedItemType: 'static + Debug + Sync + Send> UniBuilder<InType, UniChannelType, INSTRUMENTS, DerivedItemType>

pub fn new() -> Self

pub fn concurrency_limit(self, concurrency_limit: u32) -> Self

pub fn futures_timeout(self, futures_timeout: Duration) -> Self

pub fn spawn_executor<IntoString: Into<String>, OutItemType: Send + Debug, OutStreamType: Stream<Item = OutType> + Send + 'static, OutType: Future<Output = Result<OutItemType, Box<dyn Error + Send + Sync>>> + Send, ErrVoidAsyncType: Future<Output = ()> + Send + 'static, CloseVoidAsyncType: Future<Output = ()> + Send + 'static>( self, stream_name: IntoString, pipeline_builder: impl FnOnce(MutinyStream<'static, InType, UniChannelType, DerivedItemType>) -> OutStreamType, on_err_callback: impl Fn(Box<dyn Error + Send + Sync>) -> ErrVoidAsyncType + Send + Sync + 'static, on_close_callback: impl Fn(Arc<StreamExecutor<INSTRUMENTS>>) -> CloseVoidAsyncType + Send + Sync + 'static ) -> Arc<Uni<'static, InType, UniChannelType, INSTRUMENTS, DerivedItemType>>

pub fn spawn_fallibles_executor<IntoString: Into<String>, OutItemType: Send + Debug, OutStreamType: Stream<Item = Result<OutItemType, Box<dyn Error + Send + Sync>>> + Send + 'static, CloseVoidAsyncType: Future<Output = ()> + Send + 'static>( self, stream_name: IntoString, pipeline_builder: impl FnOnce(MutinyStream<'static, InType, UniChannelType, DerivedItemType>) -> OutStreamType, on_err_callback: impl Fn(Box<dyn Error + Send + Sync>) + Send + Sync + 'static, on_close_callback: impl Fn(Arc<StreamExecutor<INSTRUMENTS>>) -> CloseVoidAsyncType + Send + Sync + 'static ) -> Arc<Uni<'static, InType, UniChannelType, INSTRUMENTS, DerivedItemType>>

pub fn spawn_futures_executor<IntoString: Into<String>, OutItemType: Send + Debug, OutStreamType: Stream<Item = OutType> + Send + 'static, OutType: Future<Output = OutItemType> + Send, CloseVoidAsyncType: Future<Output = ()> + Send + 'static>( self, stream_name: IntoString, pipeline_builder: impl FnOnce(MutinyStream<'static, InType, UniChannelType, DerivedItemType>) -> OutStreamType, on_close_callback: impl Fn(Arc<StreamExecutor<INSTRUMENTS>>) -> CloseVoidAsyncType + Send + Sync + 'static ) -> Arc<Uni<'static, InType, UniChannelType, INSTRUMENTS, DerivedItemType>>

pub fn spawn_non_futures_non_fallibles_executor<IntoString: Into<String>, OutItemType: Send + Debug, OutStreamType: Stream<Item = OutItemType> + Send + 'static, CloseVoidAsyncType: Future<Output = ()> + Send + 'static>( self, stream_name: IntoString, pipeline_builder: impl FnOnce(MutinyStream<'static, InType, UniChannelType, DerivedItemType>) -> OutStreamType, on_close_callback: impl FnOnce(Arc<StreamExecutor<INSTRUMENTS>>) -> CloseVoidAsyncType + Send + Sync + 'static ) -> Arc<Uni<'static, InType, UniChannelType, INSTRUMENTS, DerivedItemType>>