Struct opentelemetry::runtime::AsyncStd

pub struct AsyncStd;

Available on crate feature rt-async-std only.

Runtime implementation, which works with async-std.

Trait Implementations

impl Clone for AsyncStd

fn clone(&self) -> AsyncStd

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AsyncStd

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Runtime for AsyncStd

type Interval = Interval

A future stream, which returns items in a previously specified interval. The item type is not important.

type Delay = Pin<Box<dyn Future<Output = ()> + Send + 'static, Global>>

A future, which resolves after a previously specified amount of time. The output type is not important.

fn interval(&self, duration: Duration) -> <AsyncStd as Runtime>::Interval

Create a [Stream][futures_util::stream::Stream], which returns a new item every Duration.

fn spawn(
    &self,
    future: Pin<Box<dyn Future<Output = ()> + Send + 'static, Global>>
)

Spawn a new task or thread, which executes the given future.

fn delay(&self, duration: Duration) -> <AsyncStd as Runtime>::Delay

Return a new future, which resolves after the specified Duration.

impl TraceRuntime for AsyncStd

type Receiver = Receiver<BatchMessage>

A future stream to receive the batch messages from channels.

type Sender = Sender<BatchMessage>

A batch messages sender that could be sent across thread safely.

fn batch_message_channel(
    &self,
    capacity: usize
) -> (<AsyncStd as TraceRuntime>::Sender, <AsyncStd as TraceRuntime>::Receiver)

Return the sender and receiver used to send batch message between tasks.