pullable_stream_builder library

Classes

HiveStorage

NullStorage

PullableStreamBuilder<T>

ResourceStreamState<T, Acc>

SharedPreferencesStorage

Storage

Functions

accumulatedBehaviourStream<T>(Stream<IList<T>> stream) → BehaviorSubject<IList<T>>

accumulatedStream<T>(Stream<IList<T>> stream) → Stream<IList<T>>

chunkedStream<T>(Stream<T> stream, {int chunkSize = 10}) → Stream<IList<T>>

defaultSkipPredicate<T>(T prev, T next) → bool

iListSkipPredicate<T>(IList<T> prev, IList<T> next) → bool

persistedAccumulatedStream(Storage storage) → PersistedIListStreamFactory

persistedIListStream(Storage storage) → PersistedIListStreamFactory

persistedStream(Storage storage) → PersistedStreamFactory

resourceStream<T, Acc>({required FutureOr<Acc> init(), required Future<ResourceStreamState<T, Acc>> process(ResourceStreamState<T, Acc> state), void cleanup(Acc)?}) → Stream<T>

streamIterator<T>(Stream<T> stream, {Option<T> initialValue = const None()}) → StreamIteratorTuple<T>

transformedBehaviorSubject<T, R>(R predicate(T)) → BehaviorSubject<R> Function(BehaviorSubject<T>)

withPullableValue<T, R>(PullableStreamState<T> value, {required R error(dynamic), required R data(T), required R loading()}) → R

Typedefs

ChunkedStreamFactory<T> = Stream<IList<T>> Function(Stream<T> stream, {int chunkSize})

PersistedIListStreamFactory = BehaviorSubject<IList<T>> Function(Stream<IList<T>>) Function<T>({required T fromJson(Object?), required String key, required Object? toJson(T)})

PersistedStreamFactory = BehaviorSubject<T> Function(Stream<T>) Function<T>({required T fromJson(Object?), required String key, bool skipPredicate(T prev, T next)?, required Object? toJson(T)})

PullableStreamState<T> = Either<dynamic, Option<T>>

PullableWidgetBuilder<T> = Widget Function(BuildContext, PullableStreamState<T>, void ())

PullFunction<T> = PullResult<T> Function()

PullResult<T> = Either<Future<Option<T>>, Option<T>>

StreamIteratorTuple<T> = Tuple2<PullFunction<T>, void Function()>