Crate discro

Discrete observables for asynchronous Functional Reactive Programming (FRP).

Crate Features

One of the following (mutually exclusive) features must be enabled to select a concrete implementation:

• tokio implementation based on tokio::sync::watch

Modules

tasklet

Tasklets for processing observed values.

Macros

upgrade_or_break

Upgrade a weak reference or break.

upgrade_or_continue

Upgrade a weak reference or continue.

upgrade_or_return

Upgrade a weak reference or return.

upgrade_or_return_abort

Upgrade a weak reference or abort the tasklet.

upgrade_or_return_continue

Upgrade a weak reference or continue the tasklet.

Structs

OrphanedSubscriberError

Indicates that the publisher has been dropped.

Publisher

Read/write a shared value and emit change notifications on write.

Ref

A borrowed reference to the shared value.

Subscriber

Read a shared value and receive change notifications asynchronously.

Functions

new_pubsub

Create a Publisher with an initial Subscriber.