stream_schedule library

Classes

Emission<T>

Interval<T>

Lifecycle<T>

Schedule<T>

Start<T>

Stop<T>

StreamElement<T>

Extensions

AsyncExpandRecursive on Stream<T>

LifecycleScheduleListExtension on Iterable<Schedule<Lifecycle<T>>>

ScheduleListExtension on Iterable<Schedule<T>>

Functions

observingElement<T>(T e) → StreamPredicate<T>

streamEmits(String streamName, dynamic value) → StreamCondition

streamStart<T>() → StreamPredicate<T>

timePassed(Duration duration) → StreamCondition

Typedefs

StreamCondition = MapEntry<Stream? Function(Map<StreamNode, Stream>), Future Function(Stream?)>

StreamPredicate<T> = bool Function(StreamElement<T>)