Module tarantool::fiber::async

Async runtime based on Tarantool fibers. Also includes sycnhronization primitives and useful traits for working with futures.

Use block_on to start the runtime.

Example

async fn foo() {
    // do something
}

use tarantool::fiber;
fiber::block_on(async {
    foo().await;
    // ... some other code
});

See also:

• Synchronization Primitives:
  • mutex
• Channels
  • oneshot
  • watch
• Extension Traits:
  • timeout::IntoTimeout
  • IntoOnDrop

Re-exports

• pub use mutex::Mutex;
• pub use futures;

Modules

• mutex
  See Mutex for examples and docs.
• oneshot
  A one-shot channel is used for sending a single message between asynchronous tasks. The channel function is used to create a Sender and Receiver handle pair that form the channel.
• timeout
  Allows a future to execute for a maximum amount of time.
• watch
  A single-producer, multi-consumer channel that only retains the last sent value.

Structs

• OnDrop
  A wrapper around a future which has on_drop behavior. See on_drop.
• RecvError
  Error that happens on the receiver side of the channel.

Traits

• IntoOnDrop
  Futures implementing this trait can attach a closure which will be executed when the future is dropped. See on_drop.

Functions

• block_on
  Runs a future to completion on the fiber-based runtime. This is the async runtime’s entry point.
• on_drop
  Adds a closure to the future, which will be executed when the future is dropped. This can be useful to cleanup external resources on future cancelation or completion.
• sleep
  An async friendly version of fiber::sleep. Prefer this version when working in async contexts.