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

• 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

• 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.