Crate crb_core

The crate includes a universal channel and a function for initiating asynchronous activities.

Re-exports

pub use futures;

Modules

mpsc

A multi-producer, single-consumer queue for sending values between asynchronous tasks.

slot

A wrapper that makes Option compatible with Result.

sync

Synchronization primitives for use in asynchronous contexts.

task

This module provides a simple wrapper around the tokio::task module.

time

unique

Implementation of a unique id.

uuid

Generate and parse universally unique identifiers (UUIDs).

watch

A multi-producer, multi-consumer channel that only retains the last sent value.

Structs

JoinHandle

An owned permission to join on a task (await its termination).

Slot

An Option that returns Error if is not filled.

SlotError

Errors with a slot. (Missing option’s error).

Unique

A unique id.

Enums

SlotErrorKind

A reason of slot interaction fail.

Traits

Msg

A message that can be sent between threads.

SyncTag

A tag that can be sent between threads.

Tag

A tag that can be sent between threads.

Functions

spawn

Spawns a new asynchronous task, returning a JoinHandle for it.

spawn_blocking

Runs the provided closure on a thread where blocking is acceptable.

spawn_local

Spawns a !Send future on the current LocalSet or LocalRuntime.