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.

Structs

Observer

Observer of a shared value.

OrphanedSubscriberError

Indicates that the publisher has been dropped.

Publisher

Publisher of a shared value.

Ref

A borrowed reference to the shared value.

Subscriber

Subscriber of a shared value.

Traits

ModifiedStatus

Return value of Publisher::modify.

Functions

subscriber_into_changed_stream

Observe modifications as a stream of changed values.

subscriber_into_changed_stream_filtered

Observe modifications as a stream of changed values.