pub struct Tokio;
Available on crate feature
rt-tokio
only.Expand description
Runtime implementation, which works with Tokio’s multi thread runtime.
Trait Implementations
sourceimpl Runtime for Tokio
impl Runtime for Tokio
type Interval = IntervalStream
type Interval = IntervalStream
A future stream, which returns items in a previously specified interval. The item type is not important. Read more
type Delay = Pin<Box<Sleep, Global>>
type Delay = Pin<Box<Sleep, Global>>
A future, which resolves after a previously specified amount of time. The output type is not important. Read more
sourceimpl TraceRuntime for Tokio
impl TraceRuntime for Tokio
type Receiver = ReceiverStream<BatchMessage>
type Receiver = ReceiverStream<BatchMessage>
A future stream to receive the batch messages from channels.
type Sender = Sender<BatchMessage>
type Sender = Sender<BatchMessage>
A batch messages sender that could be sent across thread safely.
sourcefn batch_message_channel(
&self,
capacity: usize
) -> (<Tokio as TraceRuntime>::Sender, <Tokio as TraceRuntime>::Receiver)
fn batch_message_channel(
&self,
capacity: usize
) -> (<Tokio as TraceRuntime>::Sender, <Tokio as TraceRuntime>::Receiver)
Return the sender and receiver used to send batch message between tasks.
Auto Trait Implementations
impl RefUnwindSafe for Tokio
impl Send for Tokio
impl Sync for Tokio
impl Unpin for Tokio
impl UnwindSafe for Tokio
Blanket Implementations
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more