Module strymon_job::operators::subscribe

Types for reading from topic subscriptions.

Structs

IntoIter	A blocking iterator, yielding io::Result<T, Vec<D>)> tuples.
Subscription	A subscription handle used to receive data from a topic.

Enums

SubscriptionError	Failure states when subscribting to a topic.
SubscriptionEvent	Data or frontier events emitted by a subscription.