Trait RuntimeChannel 

pub trait RuntimeChannel: Runtime {
    type Receiver<T: Debug + Send>: Stream<Item = T> + Send;
    type Sender<T: Debug + Send>: TrySend<Message = T> + Debug;

    // Required method
    fn batch_message_channel<T: Debug + Send>(
        &self,
        capacity: usize,
    ) -> (Self::Sender<T>, Self::Receiver<T>);
}

RuntimeChannel is an extension to Runtime. Currently, it provides a channel that is used by the log and span batch processors.

Required Associated Types

type Receiver<T: Debug + Send>: Stream<Item = T> + Send

A future stream to receive batch messages from channels.

type Sender<T: Debug + Send>: TrySend<Message = T> + Debug

A batch messages sender that can be sent across threads safely.

Required Methods

fn batch_message_channel<T: Debug + Send>( &self, capacity: usize, ) -> (Self::Sender<T>, Self::Receiver<T>)

Return the sender and receiver used to send batch messages.

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 RuntimeChannel for Tokio

Available on crate features experimental_async_runtime and rt-tokio only.

type Receiver<T: Debug + Send> = ReceiverStream<T>

type Sender<T: Debug + Send> = Sender<T>

impl RuntimeChannel for TokioCurrentThread

Available on crate features experimental_async_runtime and rt-tokio-current-thread only.

type Receiver<T: Debug + Send> = ReceiverStream<T>

type Sender<T: Debug + Send> = Sender<T>