Upgrading rxdart 0.22 to 0.23
Breaking0.22.6 → 0.23.1Breaking15Deprecated1New1Changed6Fixed1Other2
BreakingUpgrade verdict
11 breaking changes.
In plain terms
- You can use plain Streams directly instead of wrapping them.
- Removes Observable.just; use Stream.value instead.
- Removes Observable.error; use Stream.error instead.
- Renames *Observable classes to *Stream to reflect that they are just Streams.
Must act Top 4 of 12 that need code or config changes
Dart SDK requirement changed in 0.23.0-dev.1: >=2.0.0-dev <3.0.0 → >=2.6.0 <3.0.0.
What you must change
Breaking11
Removes the Observable class; Streams no longer need to be wrapped in a Stream.
ObservableRemoves Observable.just; use Stream.value instead.
Observable.justStream.valueRemoves Observable.error; use Stream.error instead.
Observable.errorStream.errorRenames *Observable classes to *Stream to reflect that they are just Streams.
ValueObservableValueStreamReplayObservableReplayStreamConnectableObservableConnectableStreamValueConnectableObservableValueConnectableStreamRenames ReplayConnectableObservable to ReplayConnectableStream.
ReplayConnectableObservableReplayConnectableStreamRemoves all transformation methods from the Observable class.
ObservableRemoves the deprecated ofType method; use whereType instead.
ofTypewhereTypeRemoves AsObservableFuture, MinFuture, MaxFuture, and WrappedFuture.
AsObservableFutureMinFutureMaxFutureWrappedFutureRemoves the asObservable method in chains.
asObservableExtension methods replace the Observable class; wrap-free Stream extensions are now used instead.
ObservableSubjects and *Observable classes now extend Stream instead of base Observable.
Deprecations to plan for
Deprecated1
Deprecates concatMap; use the standard Stream asyncExpand instead.
concatMapasyncExpandAPI changes
Generated by DepDelta from published Dart source. Not mixed with prose notes.
- removed:
class AsObservableFuture<T> extends WrappedFuture<T> - removed:
class StreamMaxFuture<T> extends WrappedFuture<T> - removed:
class StreamMinFuture<T> extends WrappedFuture<T> - removed:
class WrappedFuture<T> implements Future<T> - removed:
ctor AsObservableFuture(Future<T> wrapped) - removed:
ctor StreamMaxFuture(Stream<T> stream, [Comparator<T> comparator]) - removed:
ctor StreamMinFuture(Stream<T> stream, [Comparator<T> comparator]) - removed:
ctor WrappedFuture(this.wrapped) - removed:
field WrappedFuture.wrapped: final Future<T> - removed:
method AsObservableFuture.asObservable(): Observable<T> - removed:
method WrappedFuture.asStream(): Stream<T> - removed:
method WrappedFuture.catchError(Function onError, {bool test(Object error)}): Future<T> - removed:
method WrappedFuture.then<S>(FutureOr<S> onValue(T value), {Function onError}): Future<S> - removed:
method WrappedFuture.timeout(Duration timeLimit, {FutureOr<T> onTimeout()}): Future<T> - removed:
method WrappedFuture.whenComplete(void action()): Future<T>
- removed:
class AsObservableFuture<T> extends WrappedFuture<T> - removed:
class ConnectableObservable<T>: abstract extends Observable<T> - removed:
class ConnectableObservableStreamSubscription<T> extends StreamSubscription<T> - removed:
class ErrorStream<T> extends Stream<T> - removed:
class GroupByObservable<T, S> extends Observable<T> - removed:
class Observable<T> extends Stream<T> - removed:
class OfTypeStreamTransformer<T, S> extends StreamTransformerBase<T, S> - removed:
class PublishConnectableObservable<T> extends ConnectableObservable<T> - removed:
class ReplayConnectableObservable<T> extends ConnectableObservable<T> implements ReplayObservable<T> - removed:
class ReplayObservable<T>: abstract implements Observable<T> - removed:
class StreamMaxFuture<T> extends WrappedFuture<T> - removed:
class StreamMinFuture<T> extends WrappedFuture<T> - removed:
class TypeToken<S> - removed:
class ValueConnectableObservable<T> extends ConnectableObservable<T> implements ValueObservable<T> - removed:
class ValueObservable<T>: abstract implements Observable<T> - removed:
class WrappedFuture<T> implements Future<T> - removed:
ctor AsObservableFuture(Future<T> wrapped) - removed:
ctor ConnectableObservable(Stream<T> stream) - removed:
ctor ConnectableObservableStreamSubscription(this._source, this._subject) - removed:
ctor ErrorStream(this.error) - removed:
ctor GroupByObservable(this.key, Stream<T> stream) - removed:
ctor Observable(Stream<T> stream) - removed:
ctor Observable.concat(Iterable<Stream<T>> streams) - removed:
ctor Observable.concatEager(Iterable<Stream<T>> streams) - removed:
ctor Observable.defer(Stream<T> streamFactory(), {bool reusable = …}) - removed:
ctor Observable.empty() - removed:
ctor Observable.error(Object error) - removed:
ctor Observable.eventTransformed( Stream<T> source, EventSink<T> mapSink(EventSink<T> sink)) - removed:
ctor Observable.fromFuture(Future<T> future) - removed:
ctor Observable.fromIterable(Iterable<T> data) - removed:
ctor Observable.just(T data) - removed:
ctor Observable.merge(Iterable<Stream<T>> streams) - removed:
ctor Observable.never() - removed:
ctor Observable.periodic(Duration period, [T computation(int computationCount)]) - removed:
ctor Observable.race(Iterable<Stream<T>> streams) - removed:
ctor Observable.repeat(Stream<T> streamFactory(int repeatIndex), [int count]) - removed:
ctor Observable.retry(Stream<T> streamFactory(), [int count]) - removed:
ctor Observable.retryWhen(Stream<T> streamFactory(), Stream<void> retryWhenFactory(dynamic error, StackTrace stack)) - removed:
ctor Observable.switchLatest(Stream<Stream<T>> streams) - removed:
ctor Observable.timer(T value, Duration duration) - removed:
ctor OfTypeStreamTransformer(TypeToken<S> typeToken) - removed:
ctor PublishConnectableObservable(Stream<T> source) - removed:
ctor ReplayConnectableObservable(Stream<T> stream, {int maxSize}) - removed:
ctor StreamMaxFuture(Stream<T> stream, [Comparator<T> comparator]) - removed:
ctor StreamMinFuture(Stream<T> stream, [Comparator<T> comparator]) - removed:
ctor TypeToken() - removed:
ctor ValueConnectableObservable(Stream<T> source) - removed:
ctor ValueConnectableObservable.seeded( Stream<T> source, T seedValue, ) - removed:
ctor WrappedFuture(this.wrapped) - removed:
field ErrorStream.error: final Object - removed:
field GroupByObservable.key: final S - removed:
field WrappedFuture.wrapped: final Future<T> - removed:
get ConnectableObservableStreamSubscription.isPaused: bool - removed:
get Observable.first: AsObservableFuture<T> - removed:
get Observable.isBroadcast: bool - removed:
get Observable.isEmpty: AsObservableFuture<bool> - removed:
get Observable.last: AsObservableFuture<T> - removed:
get Observable.length: AsObservableFuture<int> - removed:
get Observable.single: AsObservableFuture<T> - removed:
get ReplayConnectableObservable.values: List<T> - removed:
get ReplayObservable.values: List<T> - removed:
get ValueConnectableObservable.hasValue: bool - removed:
get ValueConnectableObservable.value: T - removed:
get ValueObservable.hasValue: bool - removed:
get ValueObservable.value: T - removed:
method AsObservableFuture.asObservable(): Observable<T> - removed:
method ConnectableObservable.autoConnect({ void Function(StreamSubscription<T> subscription) connection, }): Observable<T> - removed:
method ConnectableObservable.connect(): StreamSubscription<T> - removed:
method ConnectableObservable.refCount(): Observable<T> - removed:
method ConnectableObservableStreamSubscription.asFuture<E>([E futureValue]): Future<E> - removed:
method ConnectableObservableStreamSubscription.cancel(): Future<dynamic> - removed:
method ConnectableObservableStreamSubscription.onData(void Function(T data) handleData): void - removed:
method ConnectableObservableStreamSubscription.onDone(void Function() handleDone): void - removed:
method ConnectableObservableStreamSubscription.onError(Function handleError): void - removed:
method ConnectableObservableStreamSubscription.pause([Future<dynamic> resumeSignal]): void - removed:
method ConnectableObservableStreamSubscription.resume(): void - removed:
method ErrorStream.listen(void onData(T event), {Function onError, void onDone(), bool cancelOnError}): StreamSubscription<T> - removed:
method Observable.any(bool test(T element)): AsObservableFuture<bool> - removed:
method Observable.asBroadcastStream( {void onListen(StreamSubscription<T> subscription), void onCancel(StreamSubscription<T> subscription)}): Observable<T> - removed:
method Observable.asyncExpand<S>(Stream<S> mapper(T value)): Observable<S> - removed:
method Observable.asyncMap<S>(FutureOr<S> convert(T value)): Observable<S> - removed:
method Observable.buffer(Stream window): Observable<List<T>> - removed:
method Observable.bufferCount(int count, [int startBufferEvery = …]): Observable<List<T>> - removed:
method Observable.bufferTest(bool onTestHandler(T event)): Observable<List<T>> - removed:
method Observable.bufferTime(Duration duration): Observable<List<T>> - removed:
method Observable.cast<R>(): Observable<R> - removed:
method Observable.concatMap<S>(Stream<S> mapper(T value)): Observable<S> - removed:
method Observable.concatWith(Iterable<Stream<T>> other): Observable<T> - removed:
method Observable.contains(Object needle): AsObservableFuture<bool> - removed:
method Observable.debounce(Stream window(T event)): Observable<T> - removed:
method Observable.debounceTime(Duration duration): Observable<T> - removed:
method Observable.defaultIfEmpty(T defaultValue): Observable<T> - removed:
method Observable.delay(Duration duration): Observable<T> - removed:
method Observable.dematerialize<S>(): Observable<S> - removed:
method Observable.distinct([bool equals(T previous, T next)]): Observable<T> - removed:
method Observable.distinctUnique({bool equals(T e1, T e2), int hashCode(T e)}): Observable<T> - removed:
method Observable.doOnCancel(void onCancel()): Observable<T> - removed:
method Observable.doOnData(void onData(T event)): Observable<T> - removed:
method Observable.doOnDone(void onDone()): Observable<T> - removed:
method Observable.doOnEach(void onEach(Notification<T> notification)): Observable<T> - removed:
method Observable.doOnError(Function onError): Observable<T> - removed:
method Observable.doOnListen(void onListen()): Observable<T> - removed:
method Observable.doOnPause(void onPause(Future<dynamic> resumeSignal)): Observable<T> - removed:
method Observable.doOnResume(void onResume()): Observable<T> - removed:
method Observable.drain<S>([S futureValue]): AsObservableFuture<S> - removed:
method Observable.elementAt(int index): AsObservableFuture<T> - removed:
method Observable.every(bool test(T element)): AsObservableFuture<bool> - removed:
method Observable.exhaustMap<S>(Stream<S> mapper(T value)): Observable<S> - removed:
method Observable.expand<S>(Iterable<S> convert(T value)): Observable<S> - removed:
method Observable.firstWhere(bool test(T element), {dynamic defaultValue(), T orElse()}): AsObservableFuture<T> - removed:
method Observable.flatMap<S>(Stream<S> mapper(T value)): Observable<S> - removed:
method Observable.flatMapIterable<S>(Stream<Iterable<S>> mapper(T value)): Observable<S> - removed:
method Observable.fold<S>( S initialValue, S combine(S previous, T element)): AsObservableFuture<S> - removed:
method Observable.forEach(void action(T element)): AsObservableFuture<dynamic> - removed:
method Observable.groupBy<S>(S grouper(T value)): Observable<GroupByObservable<T, S>> - removed:
method Observable.handleError(Function onError, {bool test(dynamic error)}): Observable<T> - removed:
method Observable.ignoreElements(): Observable<T> - removed:
method Observable.interval(Duration duration): Observable<T> - removed:
method Observable.join([String separator = …]): AsObservableFuture<String> - removed:
method Observable.lastWhere(bool test(T element), {Object defaultValue(), T orElse()}): AsObservableFuture<T> - removed:
method Observable.listen(void onData(T event), {Function onError, void onDone(), bool cancelOnError}): StreamSubscription<T> - removed:
method Observable.map<S>(S convert(T event)): Observable<S> - removed:
method Observable.mapTo<S>(S value): Observable<S> - removed:
method Observable.materialize(): Observable<Notification<T>> - removed:
method Observable.max([Comparator<T> comparator]): AsObservableFuture<T> - removed:
method Observable.mergeWith(Iterable<Stream<T>> streams): Observable<T> - removed:
method Observable.min([Comparator<T> comparator]): AsObservableFuture<T> - removed:
method Observable.ofType<S>(TypeToken<S> typeToken): Observable<S> - removed:
method Observable.onErrorResume(Stream<T> Function(dynamic error) recoveryFn): Observable<T> - removed:
method Observable.onErrorResumeNext(Stream<T> recoveryStream): Observable<T> - removed:
method Observable.onErrorReturn(T returnValue): Observable<T> - removed:
method Observable.onErrorReturnWith(T Function(dynamic error) returnFn): Observable<T> - removed:
method Observable.pairwise(): Observable<Iterable<T>> - removed:
method Observable.pipe(StreamConsumer<T> streamConsumer): AsObservableFuture<dynamic> - removed:
method Observable.publish(): ConnectableObservable<T> - removed:
method Observable.publishReplay({int maxSize}): ReplayConnectableObservable<T> - removed:
method Observable.publishValue(): ValueConnectableObservable<T> - removed:
method Observable.publishValueSeeded(T seedValue): ValueConnectableObservable<T> - removed:
method Observable.reduce(T combine(T previous, T element)): AsObservableFuture<T> - removed:
method Observable.sample(Stream<dynamic> sampleStream): Observable<T> - removed:
method Observable.sampleTime(Duration duration): Observable<T> - removed:
method Observable.scan<S>(S accumulator(S accumulated, T value, int index), [S seed]): Observable<S> - removed:
method Observable.share(): Observable<T> - removed:
method Observable.shareReplay({int maxSize}): ReplayObservable<T> - removed:
method Observable.shareValue(): ValueObservable<T> - removed:
method Observable.shareValueSeeded(T seedValue): ValueObservable<T> - removed:
method Observable.singleWhere(bool test(T element), {T orElse()}): AsObservableFuture<T> - removed:
method Observable.skip(int count): Observable<T> - removed:
method Observable.skipUntil<S>(Stream<S> otherStream): Observable<T> - removed:
method Observable.skipWhile(bool test(T element)): Observable<T> - removed:
method Observable.startWith(T startValue): Observable<T> - removed:
method Observable.startWithMany(List<T> startValues): Observable<T> - removed:
method Observable.switchIfEmpty(Stream<T> fallbackStream): Observable<T> - removed:
method Observable.switchMap<S>(Stream<S> mapper(T value)): Observable<S> - removed:
method Observable.take(int count): Observable<T> - removed:
method Observable.takeUntil<S>(Stream<S> otherStream): Observable<T> - removed:
method Observable.takeWhile(bool test(T element)): Observable<T> - removed:
method Observable.throttle(Stream window(T event), {bool trailing = …}): Observable<T> - removed:
method Observable.throttleTime(Duration duration, {bool trailing = …}): Observable<T> - removed:
method Observable.timeInterval(): Observable<TimeInterval<T>> - removed:
method Observable.timeout(Duration timeLimit, {void onTimeout(EventSink<T> sink)}): Observable<T> - removed:
method Observable.timestamp(): Observable<Timestamped<T>> - removed:
method Observable.toList(): AsObservableFuture<List<T>> - removed:
method Observable.toSet(): AsObservableFuture<Set<T>> - removed:
method Observable.transform<S>(StreamTransformer<T, S> streamTransformer): Observable<S> - removed:
method Observable.where(bool test(T event)): Observable<T> - removed:
method Observable.whereType<S>(): Observable<S> - removed:
method Observable.window(Stream window): Observable<Stream<T>> - removed:
method Observable.windowCount(int count, [int startBufferEvery = …]): Observable<Stream<T>> - removed:
method Observable.windowTest(bool onTestHandler(T event)): Observable<Stream<T>> - removed:
method Observable.windowTime(Duration duration): Observable<Stream<T>> - removed:
method Observable.withLatestFrom2<A, B, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, R fn(T t, A a, B b), ): Observable<R> - removed:
method Observable.withLatestFrom3<A, B, C, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, R fn(T t, A a, B b, C c), ): Observable<R> - removed:
method Observable.withLatestFrom4<A, B, C, D, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, R fn(T t, A a, B b, C c, D d), ): Observable<R> - removed:
method Observable.withLatestFrom5<A, B, C, D, E, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, R fn(T t, A a, B b, C c, D d, E e), ): Observable<R> - removed:
method Observable.withLatestFrom6<A, B, C, D, E, F, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, R fn(T t, A a, B b, C c, D d, E e, F f), ): Observable<R> - removed:
method Observable.withLatestFrom7<A, B, C, D, E, F, G, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, Stream<G> latestFromStream7, R fn(T t, A a, B b, C c, D d, E e, F f, G g), ): Observable<R> - removed:
method Observable.withLatestFrom8<A, B, C, D, E, F, G, H, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, Stream<G> latestFromStream7, Stream<H> latestFromStream8, R fn(T t, A a, B b, C c, D d, E e, F f, G g, H h), ): Observable<R> - removed:
method Observable.withLatestFrom9<A, B, C, D, E, F, G, H, I, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, Stream<G> latestFromStream7, Stream<H> latestFromStream8, Stream<I> latestFromStream9, R fn(T t, A a, B b, C c, D d, E e, F f, G g, H h, I i), ): Observable<R> - removed:
method Observable.withLatestFrom<S, R>( Stream<S> latestFromStream, R fn(T t, S s)): Observable<R> - removed:
method Observable.withLatestFromList( Iterable<Stream<T>> latestFromStreams): Observable<List<T>> - removed:
method Observable.zipWith<S, R>(Stream<S> other, R zipper(T t, S s)): Observable<R> - removed:
method OfTypeStreamTransformer.bind(Stream<T> stream): Stream<S> - removed:
method PublishConnectableObservable.autoConnect({ void Function(StreamSubscription<T> subscription) connection, }): Observable<T> - removed:
method PublishConnectableObservable.connect(): StreamSubscription<T> - removed:
method PublishConnectableObservable.refCount(): Observable<T> - removed:
method ReplayConnectableObservable.autoConnect({ void Function(StreamSubscription<T> subscription) connection, }): ReplayObservable<T> - removed:
method ReplayConnectableObservable.connect(): StreamSubscription<T> - removed:
method ReplayConnectableObservable.refCount(): ReplayObservable<T> - removed:
method TypeToken.isType(dynamic other): bool - removed:
method TypeToken.toType(dynamic other): S - removed:
method ValueConnectableObservable.autoConnect({ void Function(StreamSubscription<T> subscription) connection, }): ValueObservable<T> - removed:
method ValueConnectableObservable.connect(): StreamSubscription<T> - removed:
method ValueConnectableObservable.refCount(): ValueObservable<T> - removed:
method WrappedFuture.asStream(): Stream<T> - removed:
method WrappedFuture.catchError(Function onError, {bool test(Object error)}): Future<T> - removed:
method WrappedFuture.then<S>(FutureOr<S> onValue(T value), {Function onError}): Future<S> - removed:
method WrappedFuture.timeout(Duration timeLimit, {FutureOr<T> onTimeout()}): Future<T> - removed:
method WrappedFuture.whenComplete(void action()): Future<T> - removed:
static method Observable.combineLatest2<A, B, T>( Stream<A> streamA, Stream<B> streamB, T combiner(A a, B b)): Observable<T> - removed:
static method Observable.combineLatest3<A, B, C, T>(Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, T combiner(A a, B b, C c)): Observable<T> - removed:
static method Observable.combineLatest4<A, B, C, D, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, T combiner(A a, B b, C c, D d)): Observable<T> - removed:
static method Observable.combineLatest5<A, B, C, D, E, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, T combiner(A a, B b, C c, D d, E e)): Observable<T> - removed:
static method Observable.combineLatest6<A, B, C, D, E, F, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, T combiner(A a, B b, C c, D d, E e, F f)): Observable<T> - removed:
static method Observable.combineLatest7<A, B, C, D, E, F, G, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, T combiner(A a, B b, C c, D d, E e, F f, G g)): Observable<T> - removed:
static method Observable.combineLatest8<A, B, C, D, E, F, G, H, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, T combiner(A a, B b, C c, D d, E e, F f, G g, H h)): Observable<T> - removed:
static method Observable.combineLatest9<A, B, C, D, E, F, G, H, I, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, Stream<I> streamI, T combiner(A a, B b, C c, D d, E e, F f, G g, H h, I i)): Observable<T> - removed:
static method Observable.combineLatest<T, R>( Iterable<Stream<T>> streams, R combiner(List<T> values)): Observable<R> - removed:
static method Observable.combineLatestList<T>( Iterable<Stream<T>> streams): Observable<List<T>> - removed:
static method Observable.forkJoin2<A, B, T>( Stream<A> streamA, Stream<B> streamB, T combiner(A a, B b)): Observable<T> - removed:
static method Observable.forkJoin3<A, B, C, T>(Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, T combiner(A a, B b, C c)): Observable<T> - removed:
static method Observable.forkJoin4<A, B, C, D, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, T combiner(A a, B b, C c, D d)): Observable<T> - removed:
static method Observable.forkJoin5<A, B, C, D, E, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, T combiner(A a, B b, C c, D d, E e)): Observable<T> - removed:
static method Observable.forkJoin6<A, B, C, D, E, F, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, T combiner(A a, B b, C c, D d, E e, F f)): Observable<T> - removed:
static method Observable.forkJoin7<A, B, C, D, E, F, G, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, T combiner(A a, B b, C c, D d, E e, F f, G g)): Observable<T> - removed:
static method Observable.forkJoin8<A, B, C, D, E, F, G, H, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, T combiner(A a, B b, C c, D d, E e, F f, G g, H h)): Observable<T> - removed:
static method Observable.forkJoin9<A, B, C, D, E, F, G, H, I, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, Stream<I> streamI, T combiner(A a, B b, C c, D d, E e, F f, G g, H h, I i)): Observable<T> - removed:
static method Observable.forkJoin<T, R>( Iterable<Stream<T>> streams, R combiner(List<T> values)): Observable<R> - removed:
static method Observable.forkJoinList<T>(Iterable<Stream<T>> streams): Observable<List<T>> - removed:
static method Observable.range(int startInclusive, int endInclusive): Observable<int> - removed:
static method Observable.sequenceEqual<A, B>(Stream<A> stream, Stream<B> other, {bool equals(A a, B b)}): Observable<bool> - removed:
static method Observable.zip2<A, B, T>( Stream<A> streamA, Stream<B> streamB, T zipper(A a, B b)): Observable<T> - removed:
static method Observable.zip3<A, B, C, T>(Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, T zipper(A a, B b, C c)): Observable<T> - removed:
static method Observable.zip4<A, B, C, D, T>(Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, T zipper(A a, B b, C c, D d)): Observable<T> - removed:
static method Observable.zip5<A, B, C, D, E, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, T zipper(A a, B b, C c, D d, E e)): Observable<T> - removed:
static method Observable.zip6<A, B, C, D, E, F, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, T zipper(A a, B b, C c, D d, E e, F f)): Observable<T> - removed:
static method Observable.zip7<A, B, C, D, E, F, G, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, T zipper(A a, B b, C c, D d, E e, F f, G g)): Observable<T> - removed:
static method Observable.zip8<A, B, C, D, E, F, G, H, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, T zipper(A a, B b, C c, D d, E e, F f, G g, H h)): Observable<T> - removed:
static method Observable.zip9<A, B, C, D, E, F, G, H, I, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, Stream<I> streamI, T zipper(A a, B b, C c, D d, E e, F f, G g, H h, I i)): Observable<T> - removed:
static method Observable.zip<T, R>( Iterable<Stream<T>> streams, R zipper(List<T> values)): Observable<R> - removed:
static method Observable.zipList<T>(Iterable<Stream<T>> streams): Observable<List<T>> - removed:
variable kBool: const TypeToken<bool> - removed:
variable kDouble: const TypeToken<double> - removed:
variable kInt: const TypeToken<int> - removed:
variable kNum: const TypeToken<num> - removed:
variable kString: const TypeToken<String> - removed:
variable kSymbol: const TypeToken<Symbol> - changed:
class BehaviorSubject<T> extends Subject<T> implements ValueObservable<T> → class BehaviorSubject<T> extends Subject<T> implements ValueStream<T> - changed:
class GroupByStreamTransformer<T, S> extends StreamTransformerBase<T, GroupByObservable<T, S>> → class GroupByStreamTransformer<T, S> extends StreamTransformerBase<T, GroupByStream<T, S>> - changed:
class ReplaySubject<T> extends Subject<T> implements ReplayObservable<T> → class ReplaySubject<T> extends Subject<T> implements ReplayStream<T> - changed:
class Subject<T>: abstract extends Observable<T> implements StreamController<T> → class Subject<T>: abstract extends StreamView<T> implements StreamController<T> - changed:
ctor BehaviorSubject({ void onListen(), void onCancel(), bool sync = …, }) → ctor BehaviorSubject({ void Function() onListen, void Function() onCancel, bool sync = …, }) - changed:
ctor BehaviorSubject.seeded( T seedValue, { void onListen(), void onCancel(), bool sync = …, }) → ctor BehaviorSubject.seeded( T seedValue, { void Function() onListen, void Function() onCancel, bool sync = …, }) - changed:
ctor BufferStreamTransformer(Stream window(T event)) → ctor BufferStreamTransformer(Stream Function(T event) window) - changed:
ctor BufferTestStreamTransformer(bool test(T value)) → ctor BufferTestStreamTransformer(bool Function(T value) test) - changed:
ctor CombineLatestStream( Iterable<Stream<T>> streams, R combiner(List<T> values), ) → ctor CombineLatestStream( Iterable<Stream<T>> streams, R Function(List<T> values) combiner, ) - changed:
ctor DebounceStreamTransformer(Stream window(T event)) → ctor DebounceStreamTransformer(Stream Function(T event) window) - changed:
ctor DeferStream(Stream<T> streamFactory(), {bool reusable = …}) → ctor DeferStream(Stream<T> Function() streamFactory, {bool reusable = …}) - changed:
ctor DistinctUniqueStreamTransformer({bool equals(T e1, T e2), int hashCode(T e)}) → ctor DistinctUniqueStreamTransformer( {bool Function(T e1, T e2) equals, int Function(T e) hashCode}) - changed:
ctor DoStreamTransformer( {void onCancel(), void onData(T event), void onDone(), void onEach(Notification<T> notification), Function onError, void onListen(), void onPause(Future<dynamic> resumeSignal), void onResume()}) → ctor DoStreamTransformer( {dynamic Function() onCancel, void Function(T event) onData, void Function() onDone, void Function(Notification<T> notification) onEach, Function onError, void Function() onListen, void Function(Future<dynamic> resumeSignal) onPause, void Function() onResume}) - changed:
ctor ExhaustMapStreamTransformer(Stream<S> mapper(T value)) → ctor ExhaustMapStreamTransformer(Stream<S> Function(T value) mapper) - changed:
ctor FlatMapStreamTransformer(Stream<S> mapper(T value)) → ctor FlatMapStreamTransformer(Stream<S> Function(T value) mapper) - changed:
ctor ForkJoinStream( Iterable<Stream<T>> streams, R combiner(List<T> values), ) → ctor ForkJoinStream( Iterable<Stream<T>> streams, R Function(List<T> values) combiner, ) - changed:
ctor GroupByStreamTransformer(S grouper(T event)) → ctor GroupByStreamTransformer(S Function(T event) grouper) - changed:
ctor PublishSubject( {void onListen(), void onCancel(), bool sync = …}) → ctor PublishSubject( {void Function() onListen, void Function() onCancel, bool sync = …}) - changed:
ctor ReplaySubject({ int maxSize, void onListen(), void onCancel(), bool sync = …, }) → ctor ReplaySubject({ int maxSize, void Function() onListen, void Function() onCancel, bool sync = …, }) - changed:
ctor SampleStreamTransformer(Stream window(T event)) → ctor SampleStreamTransformer(Stream Function(T event) window) - changed:
ctor ScanStreamTransformer(S accumulator(S accumulated, T value, int index), [S seed]) → ctor ScanStreamTransformer( S Function(S accumulated, T value, int index) accumulator, [S seed]) - changed:
ctor SequenceEqualStream(Stream<S> stream, Stream<T> other, {bool equals(S s, T t)}) → ctor SequenceEqualStream(Stream<S> stream, Stream<T> other, {bool Function(S s, T t) equals}) - changed:
ctor Subject(StreamController<T> controller, Observable<T> observable) → ctor Subject(StreamController<T> controller, Stream<T> stream) - changed:
ctor SwitchMapStreamTransformer(Stream<S> mapper(T value)) → ctor SwitchMapStreamTransformer(Stream<S> Function(T value) mapper) - changed:
ctor ThrottleStreamTransformer(Stream window(T event), {bool trailing = …}) → ctor ThrottleStreamTransformer( Stream Function(T event) window, { bool trailing = …, }) - changed:
ctor WindowStreamTransformer(Stream window(T event)) → ctor WindowStreamTransformer(Stream Function(T event) window) - changed:
ctor WindowTestStreamTransformer(bool test(T value)) → ctor WindowTestStreamTransformer(bool Function(T value) test) - changed:
ctor WithLatestFromStreamTransformer( Iterable<Stream<S>> latestFromStreams, R fn(T t, List<S> values)) → ctor WithLatestFromStreamTransformer( Iterable<Stream<S>> latestFromStreams, R Function(T t, List<S> values) fn) - changed:
ctor ZipStream( Iterable<Stream<T>> streams, R zipper(List<T> values), ) → ctor ZipStream( Iterable<Stream<T>> streams, R Function(List<T> values) zipper, ) - changed:
get BehaviorSubject.stream: ValueObservable<T> → get BehaviorSubject.stream: ValueStream<T> - changed:
get Subject.stream: Observable<T> → get Subject.stream: Stream<T> - changed:
method ConcatEagerStream.listen(void onData(T event), {Function onError, void onDone(), bool cancelOnError}): StreamSubscription<T> → method ConcatEagerStream.listen(void Function(T event) onData, {Function onError, void Function() onDone, bool cancelOnError}): StreamSubscription<T> - changed:
method ConcatStream.listen(void onData(T event), {Function onError, void onDone(), bool cancelOnError}): StreamSubscription<T> → method ConcatStream.listen( void Function(T event) onData, { Function onError, void Function() onDone, bool cancelOnError, }): StreamSubscription<T> - changed:
method DeferStream.listen(void onData(T event), {Function onError, void onDone(), bool cancelOnError}): StreamSubscription<T> → method DeferStream.listen(void Function(T event) onData, {Function onError, void Function() onDone, bool cancelOnError}): StreamSubscription<T> - changed:
method GroupByStreamTransformer.bind(Stream<T> stream): Stream<GroupByObservable<T, S>> → method GroupByStreamTransformer.bind(Stream<T> stream): Stream<GroupByStream<T, S>> - changed:
method MergeStream.listen(void onData(T event), {Function onError, void onDone(), bool cancelOnError}): StreamSubscription<T> → method MergeStream.listen(void Function(T event) onData, {Function onError, void Function() onDone, bool cancelOnError}): StreamSubscription<T> - changed:
method NeverStream.listen(void onData(T event), {Function onError, void onDone(), bool cancelOnError}): StreamSubscription<T> → method NeverStream.listen(void Function(T event) onData, {Function onError, void Function() onDone, bool cancelOnError}): StreamSubscription<T> - changed:
method RaceStream.listen(void onData(T event), {Function onError, void onDone(), bool cancelOnError}): StreamSubscription<T> → method RaceStream.listen(void Function(T event) onData, {Function onError, void Function() onDone, bool cancelOnError}): StreamSubscription<T> - changed:
method RangeStream.listen(void onData(int event), {Function onError, void onDone(), bool cancelOnError}): StreamSubscription<int> → method RangeStream.listen(void Function(int event) onData, {Function onError, void Function() onDone, bool cancelOnError}): StreamSubscription<int> - changed:
method RepeatStream.listen( void onData(T event), { Function onError, void onDone(), bool cancelOnError, }): StreamSubscription<T> → method RepeatStream.listen( void Function(T event) onData, { Function onError, void Function() onDone, bool cancelOnError, }): StreamSubscription<T> - changed:
method RetryStream.listen( void onData(T event), { Function onError, void onDone(), bool cancelOnError, }): StreamSubscription<T> → method RetryStream.listen( void Function(T event) onData, { Function onError, void Function() onDone, bool cancelOnError, }): StreamSubscription<T> - changed:
method RetryWhenStream.listen( void onData(T event), { Function onError, void onDone(), bool cancelOnError, }): StreamSubscription<T> → method RetryWhenStream.listen( void Function(T event) onData, { Function onError, void Function() onDone, bool cancelOnError, }): StreamSubscription<T> - changed:
method SequenceEqualStream.listen(void onData(bool event), {Function onError, void onDone(), bool cancelOnError}): StreamSubscription<bool> → method SequenceEqualStream.listen(void Function(bool event) onData, {Function onError, void Function() onDone, bool cancelOnError}): StreamSubscription<bool> - changed:
method SwitchLatestStream.listen( void onData(T event), { Function onError, void onDone(), bool cancelOnError, }): StreamSubscription<T> → method SwitchLatestStream.listen( void Function(T event) onData, { Function onError, void Function() onDone, bool cancelOnError, }): StreamSubscription<T> - changed:
set Subject.onCancel(void onCancelHandler()) → set Subject.onCancel(void Function() onCancelHandler) - changed:
set Subject.onListen(void onListenHandler()) → set Subject.onListen(void Function() onListenHandler) - changed:
set Subject.onPause(void onPauseHandler()) → set Subject.onPause(void Function() onPauseHandler) - changed:
set Subject.onResume(void onResumeHandler()) → set Subject.onResume(void Function() onResumeHandler) - changed:
static method CombineLatestStream.combine2<A, B, R>( Stream<A> streamOne, Stream<B> streamTwo, R combiner(A a, B b), ): CombineLatestStream<dynamic, R> → static method CombineLatestStream.combine2<A, B, R>( Stream<A> streamOne, Stream<B> streamTwo, R Function(A a, B b) combiner, ): CombineLatestStream<dynamic, R> - changed:
static method CombineLatestStream.combine3<A, B, C, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, R combiner(A a, B b, C c), ): CombineLatestStream<dynamic, R> → static method CombineLatestStream.combine3<A, B, C, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, R Function(A a, B b, C c) combiner, ): CombineLatestStream<dynamic, R> - changed:
static method CombineLatestStream.combine4<A, B, C, D, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, R combiner(A a, B b, C c, D d), ): CombineLatestStream<dynamic, R> → static method CombineLatestStream.combine4<A, B, C, D, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, R Function(A a, B b, C c, D d) combiner, ): CombineLatestStream<dynamic, R> - changed:
static method CombineLatestStream.combine5<A, B, C, D, E, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, R combiner(A a, B b, C c, D d, E e), ): CombineLatestStream<dynamic, R> → static method CombineLatestStream.combine5<A, B, C, D, E, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, R Function(A a, B b, C c, D d, E e) combiner, ): CombineLatestStream<dynamic, R> - changed:
static method CombineLatestStream.combine6<A, B, C, D, E, F, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, R combiner(A a, B b, C c, D d, E e, F f), ): CombineLatestStream<dynamic, R> → static method CombineLatestStream.combine6<A, B, C, D, E, F, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, R Function(A a, B b, C c, D d, E e, F f) combiner, ): CombineLatestStream<dynamic, R> - changed:
static method CombineLatestStream.combine7<A, B, C, D, E, F, G, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, R combiner(A a, B b, C c, D d, E e, F f, G g), ): CombineLatestStream<dynamic, R> → static method CombineLatestStream.combine7<A, B, C, D, E, F, G, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, R Function(A a, B b, C c, D d, E e, F f, G g) combiner, ): CombineLatestStream<dynamic, R> - changed:
static method CombineLatestStream.combine8<A, B, C, D, E, F, G, H, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, R combiner(A a, B b, C c, D d, E e, F f, G g, H h), ): CombineLatestStream<dynamic, R> → static method CombineLatestStream.combine8<A, B, C, D, E, F, G, H, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, R Function(A a, B b, C c, D d, E e, F f, G g, H h) combiner, ): CombineLatestStream<dynamic, R> - changed:
static method CombineLatestStream.combine9<A, B, C, D, E, F, G, H, I, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, Stream<I> streamI, R combiner(A a, B b, C c, D d, E e, F f, G g, H h, I i), ): CombineLatestStream<dynamic, R> → static method CombineLatestStream.combine9<A, B, C, D, E, F, G, H, I, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, Stream<I> streamI, R Function(A a, B b, C c, D d, E e, F f, G g, H h, I i) combiner, ): CombineLatestStream<dynamic, R> - changed:
static method ForkJoinStream.combine2<A, B, R>( Stream<A> streamOne, Stream<B> streamTwo, R combiner(A a, B b), ): ForkJoinStream<dynamic, R> → static method ForkJoinStream.combine2<A, B, R>( Stream<A> streamOne, Stream<B> streamTwo, R Function(A a, B b) combiner, ): ForkJoinStream<dynamic, R> - changed:
static method ForkJoinStream.combine3<A, B, C, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, R combiner(A a, B b, C c), ): ForkJoinStream<dynamic, R> → static method ForkJoinStream.combine3<A, B, C, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, R Function(A a, B b, C c) combiner, ): ForkJoinStream<dynamic, R> - changed:
static method ForkJoinStream.combine4<A, B, C, D, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, R combiner(A a, B b, C c, D d), ): ForkJoinStream<dynamic, R> → static method ForkJoinStream.combine4<A, B, C, D, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, R Function(A a, B b, C c, D d) combiner, ): ForkJoinStream<dynamic, R> - changed:
static method ForkJoinStream.combine5<A, B, C, D, E, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, R combiner(A a, B b, C c, D d, E e), ): ForkJoinStream<dynamic, R> → static method ForkJoinStream.combine5<A, B, C, D, E, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, R Function(A a, B b, C c, D d, E e) combiner, ): ForkJoinStream<dynamic, R> - changed:
static method ForkJoinStream.combine6<A, B, C, D, E, F, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, R combiner(A a, B b, C c, D d, E e, F f), ): ForkJoinStream<dynamic, R> → static method ForkJoinStream.combine6<A, B, C, D, E, F, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, R Function(A a, B b, C c, D d, E e, F f) combiner, ): ForkJoinStream<dynamic, R> - changed:
static method ForkJoinStream.combine7<A, B, C, D, E, F, G, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, R combiner(A a, B b, C c, D d, E e, F f, G g), ): ForkJoinStream<dynamic, R> → static method ForkJoinStream.combine7<A, B, C, D, E, F, G, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, R Function(A a, B b, C c, D d, E e, F f, G g) combiner, ): ForkJoinStream<dynamic, R> - changed:
static method ForkJoinStream.combine8<A, B, C, D, E, F, G, H, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, R combiner(A a, B b, C c, D d, E e, F f, G g, H h), ): ForkJoinStream<dynamic, R> → static method ForkJoinStream.combine8<A, B, C, D, E, F, G, H, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, R Function(A a, B b, C c, D d, E e, F f, G g, H h) combiner, ): ForkJoinStream<dynamic, R> - changed:
static method ForkJoinStream.combine9<A, B, C, D, E, F, G, H, I, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, Stream<I> streamI, R combiner(A a, B b, C c, D d, E e, F f, G g, H h, I i), ): ForkJoinStream<dynamic, R> → static method ForkJoinStream.combine9<A, B, C, D, E, F, G, H, I, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, Stream<I> streamI, R Function(A a, B b, C c, D d, E e, F f, G g, H h, I i) combiner, ): ForkJoinStream<dynamic, R> - changed:
static method WithLatestFromStreamTransformer.with1<T, S, R>( Stream<S> latestFromStream, R fn(T t, S s), ): WithLatestFromStreamTransformer<T, S, R> → static method WithLatestFromStreamTransformer.with1<T, S, R>( Stream<S> latestFromStream, R Function(T t, S s) fn, ): WithLatestFromStreamTransformer<T, S, R> - changed:
static method WithLatestFromStreamTransformer.with2<T, A, B, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, R fn(T t, A a, B b), ): WithLatestFromStreamTransformer<T, dynamic, R> → static method WithLatestFromStreamTransformer.with2<T, A, B, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, R Function(T t, A a, B b) fn, ): WithLatestFromStreamTransformer<T, dynamic, R> - changed:
static method WithLatestFromStreamTransformer.with3<T, A, B, C, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, R fn(T t, A a, B b, C c), ): WithLatestFromStreamTransformer<T, dynamic, R> → static method WithLatestFromStreamTransformer.with3<T, A, B, C, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, R Function(T t, A a, B b, C c) fn, ): WithLatestFromStreamTransformer<T, dynamic, R> - changed:
static method WithLatestFromStreamTransformer.with4<T, A, B, C, D, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, R fn(T t, A a, B b, C c, D d), ): WithLatestFromStreamTransformer<T, dynamic, R> → static method WithLatestFromStreamTransformer.with4<T, A, B, C, D, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, R Function(T t, A a, B b, C c, D d) fn, ): WithLatestFromStreamTransformer<T, dynamic, R> - changed:
static method WithLatestFromStreamTransformer.with5<T, A, B, C, D, E, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, R fn(T t, A a, B b, C c, D d, E e), ): WithLatestFromStreamTransformer<T, dynamic, R> → static method WithLatestFromStreamTransformer.with5<T, A, B, C, D, E, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, R Function(T t, A a, B b, C c, D d, E e) fn, ): WithLatestFromStreamTransformer<T, dynamic, R> - changed:
static method WithLatestFromStreamTransformer.with6<T, A, B, C, D, E, F, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, R fn(T t, A a, B b, C c, D d, E e, F f), ): WithLatestFromStreamTransformer<T, dynamic, R> → static method WithLatestFromStreamTransformer.with6<T, A, B, C, D, E, F, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, R Function(T t, A a, B b, C c, D d, E e, F f) fn, ): WithLatestFromStreamTransformer<T, dynamic, R> - changed:
static method WithLatestFromStreamTransformer.with7<T, A, B, C, D, E, F, G, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, Stream<G> latestFromStream7, R fn(T t, A a, B b, C c, D d, E e, F f, G g), ): WithLatestFromStreamTransformer<T, dynamic, R> → static method WithLatestFromStreamTransformer.with7<T, A, B, C, D, E, F, G, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, Stream<G> latestFromStream7, R Function(T t, A a, B b, C c, D d, E e, F f, G g) fn, ): WithLatestFromStreamTransformer<T, dynamic, R> - changed:
static method WithLatestFromStreamTransformer.with8<T, A, B, C, D, E, F, G, H, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, Stream<G> latestFromStream7, Stream<H> latestFromStream8, R fn(T t, A a, B b, C c, D d, E e, F f, G g, H h), ): WithLatestFromStreamTransforme… → static method WithLatestFromStreamTransformer.with8<T, A, B, C, D, E, F, G, H, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, Stream<G> latestFromStream7, Stream<H> latestFromStream8, R Function(T t, A a, B b, C c, D d, E e, F f, G g, H h) fn, ): WithLatestFromStreamT… - changed:
static method WithLatestFromStreamTransformer.with9<T, A, B, C, D, E, F, G, H, I, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, Stream<G> latestFromStream7, Stream<H> latestFromStream8, Stream<I> latestFromStream9, R fn(T t, A a, B b, C c, D d, E e, F f, G g, H h, I… → static method WithLatestFromStreamTransformer.with9<T, A, B, C, D, E, F, G, H, I, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, Stream<G> latestFromStream7, Stream<H> latestFromStream8, Stream<I> latestFromStream9, R Function(T t, A a, B b, C c, D d, E e, F f, G g, H… - changed:
static method ZipStream.zip2<A, B, R>( Stream<A> streamOne, Stream<B> streamTwo, R zipper(A a, B b), ): ZipStream<dynamic, R> → static method ZipStream.zip2<A, B, R>( Stream<A> streamOne, Stream<B> streamTwo, R Function(A a, B b) zipper, ): ZipStream<dynamic, R> - changed:
static method ZipStream.zip3<A, B, C, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, R zipper(A a, B b, C c), ): ZipStream<dynamic, R> → static method ZipStream.zip3<A, B, C, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, R Function(A a, B b, C c) zipper, ): ZipStream<dynamic, R> - changed:
static method ZipStream.zip4<A, B, C, D, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, R zipper(A a, B b, C c, D d), ): ZipStream<dynamic, R> → static method ZipStream.zip4<A, B, C, D, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, R Function(A a, B b, C c, D d) zipper, ): ZipStream<dynamic, R> - changed:
static method ZipStream.zip5<A, B, C, D, E, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, R zipper(A a, B b, C c, D d, E e), ): ZipStream<dynamic, R> → static method ZipStream.zip5<A, B, C, D, E, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, R Function(A a, B b, C c, D d, E e) zipper, ): ZipStream<dynamic, R> - changed:
static method ZipStream.zip6<A, B, C, D, E, F, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, R zipper(A a, B b, C c, D d, E e, F f), ): ZipStream<dynamic, R> → static method ZipStream.zip6<A, B, C, D, E, F, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, R Function(A a, B b, C c, D d, E e, F f) zipper, ): ZipStream<dynamic, R> - changed:
static method ZipStream.zip7<A, B, C, D, E, F, G, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, R zipper(A a, B b, C c, D d, E e, F f, G g), ): ZipStream<dynamic, R> → static method ZipStream.zip7<A, B, C, D, E, F, G, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, R Function(A a, B b, C c, D d, E e, F f, G g) zipper, ): ZipStream<dynamic, R> - changed:
static method ZipStream.zip8<A, B, C, D, E, F, G, H, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, R zipper(A a, B b, C c, D d, E e, F f, G g, H h), ): ZipStream<dynamic, R> → static method ZipStream.zip8<A, B, C, D, E, F, G, H, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, R Function(A a, B b, C c, D d, E e, F f, G g, H h) zipper, ): ZipStream<dynamic, R> - changed:
static method ZipStream.zip9<A, B, C, D, E, F, G, H, I, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, Stream<I> streamI, R zipper(A a, B b, C c, D d, E e, F f, G g, H h, I i), ): ZipStream<dynamic, R> → static method ZipStream.zip9<A, B, C, D, E, F, G, H, I, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, Stream<I> streamI, R Function(A a, B b, C c, D d, E e, F f, G g, H h, I i) zipper, ): ZipStream<dynamic, R> - added:
class ConnectableStream<T>: abstract extends StreamView<T> - added:
class ConnectableStreamSubscription<T> extends StreamSubscription<T> - added:
class GroupByStream<T, S> extends StreamView<T> - added:
class PublishConnectableStream<T> extends ConnectableStream<T> - added:
class ReplayConnectableStream<T> extends ConnectableStream<T> implements ReplayStream<T> - added:
class ReplayStream<T>: abstract implements Stream<T> - added:
class Rx: abstract - added:
class ValueConnectableStream<T> extends ConnectableStream<T> implements ValueStream<T> - added:
class ValueStream<T>: abstract implements Stream<T> - added:
ctor ConnectableStream(Stream<T> stream) - added:
ctor ConnectableStreamSubscription(this._source, this._subject) - added:
ctor GroupByStream(this.key, Stream<T> stream) - added:
ctor PublishConnectableStream(Stream<T> source) - added:
ctor ReplayConnectableStream(Stream<T> stream, {int maxSize}) - added:
ctor ValueConnectableStream(Stream<T> source) - added:
ctor ValueConnectableStream.seeded( Stream<T> source, T seedValue, ) - added:
extension BufferExtensions<T> on Stream<T> - added:
extension ConcatExtensions<T> on Stream<T> - added:
extension ConnectableStreamExtensions<T> on Stream<T> - added:
extension DebounceExtensions<T> on Stream<T> - added:
extension DefaultIfEmptyExtension<T> on Stream<T> - added:
extension DelayExtension<T> on Stream<T> - added:
extension DematerializeExtension<T> on Stream<Notification<T>> - added:
extension DistinctUniqueExtension<T> on Stream<T> - added:
extension DoExtensions<T> on Stream<T> - added:
extension ExhaustMapExtension<T> on Stream<T> - added:
extension FlatMapExtension<T> on Stream<T> - added:
extension GroupByExtension<T> on Stream<T> - added:
extension IgnoreElementsExtension<T> on Stream<T> - added:
extension IntervalExtension<T> on Stream<T> - added:
extension MapToExtension<T> on Stream<T> - added:
extension MaterializeExtension<T> on Stream<T> - added:
extension MaxExtension<T> on Stream<T> - added:
extension MergeExtension<T> on Stream<T> - added:
extension MinExtension<T> on Stream<T> - added:
extension OnErrorExtensions<T> on Stream<T> - added:
extension PairwiseExtension<T> on Stream<T> - added:
extension SampleExtensions<T> on Stream<T> - added:
extension ScanExtension<T> on Stream<T> - added:
extension SkipUntilExtension<T> on Stream<T> - added:
extension StartWithExtension<T> on Stream<T> - added:
extension StartWithManyExtension<T> on Stream<T> - added:
extension SwitchIfEmptyExtension<T> on Stream<T> - added:
extension SwitchMapExtension<T> on Stream<T> - added:
extension TakeUntilExtension<T> on Stream<T> - added:
extension ThrottleExtensions<T> on Stream<T> - added:
extension TimeIntervalExtension<T> on Stream<T> - added:
extension TimeStampExtension<T> on Stream<T> - added:
extension WhereTypeExtension<T> on Stream<T> - added:
extension WindowExtensions<T> on Stream<T> - added:
extension WithLatestFromExtensions<T> on Stream<T> - added:
extension ZipWithExtension<T> on Stream<T> - added:
field GroupByStream.key: final S - added:
get ConnectableStreamSubscription.isPaused: bool - added:
get ReplayConnectableStream.values: List<T> - added:
get ReplayStream.values: List<T> - added:
get ValueConnectableStream.hasValue: bool - added:
get ValueConnectableStream.value: T - added:
get ValueStream.hasValue: bool - added:
get ValueStream.value: T - added:
method BufferExtensions.buffer(Stream window): Stream<List<T>> - added:
method BufferExtensions.bufferCount(int count, [int startBufferEvery = …]): Stream<List<T>> - added:
method BufferExtensions.bufferTest(bool Function(T event) onTestHandler): Stream<List<T>> - added:
method BufferExtensions.bufferTime(Duration duration): Stream<List<T>> - added:
method ConcatExtensions.concatWith(Iterable<Stream<T>> other): Stream<T> - added:
method ConnectableStream.autoConnect({ void Function(StreamSubscription<T> subscription) connection, }): Stream<T> - added:
method ConnectableStream.connect(): StreamSubscription<T> - added:
method ConnectableStream.refCount(): Stream<T> - added:
method ConnectableStreamExtensions.publish(): ConnectableStream<T> - added:
method ConnectableStreamExtensions.publishReplay({int maxSize}): ReplayConnectableStream<T> - added:
method ConnectableStreamExtensions.publishValue(): ValueConnectableStream<T> - added:
method ConnectableStreamExtensions.publishValueSeeded(T seedValue): ValueConnectableStream<T> - added:
method ConnectableStreamExtensions.share(): Stream<T> - added:
method ConnectableStreamExtensions.shareReplay({int maxSize}): ReplayStream<T> - added:
method ConnectableStreamExtensions.shareValue(): ValueStream<T> - added:
method ConnectableStreamExtensions.shareValueSeeded(T seedValue): ValueStream<T> - added:
method ConnectableStreamSubscription.asFuture<E>([E futureValue]): Future<E> - added:
method ConnectableStreamSubscription.cancel(): Future<dynamic> - added:
method ConnectableStreamSubscription.onData(void Function(T data) handleData): void - added:
method ConnectableStreamSubscription.onDone(void Function() handleDone): void - added:
method ConnectableStreamSubscription.onError(Function handleError): void - added:
method ConnectableStreamSubscription.pause([Future<dynamic> resumeSignal]): void - added:
method ConnectableStreamSubscription.resume(): void - added:
method DebounceExtensions.debounce(Stream Function(T event) window): Stream<T> - added:
method DebounceExtensions.debounceTime(Duration duration): Stream<T> - added:
method DefaultIfEmptyExtension.defaultIfEmpty(T defaultValue): Stream<T> - added:
method DelayExtension.delay(Duration duration): Stream<T> - added:
method DematerializeExtension.dematerialize(): Stream<T> - added:
method DistinctUniqueExtension.distinctUnique({ bool Function(T e1, T e2) equals, int Function(T e) hashCode, }): Stream<T> - added:
method DoExtensions.doOnCancel(void Function() onCancel): Stream<T> - added:
method DoExtensions.doOnData(void Function(T event) onData): Stream<T> - added:
method DoExtensions.doOnDone(void Function() onDone): Stream<T> - added:
method DoExtensions.doOnEach(void Function(Notification<T> notification) onEach): Stream<T> - added:
method DoExtensions.doOnError(Function onError): Stream<T> - added:
method DoExtensions.doOnListen(void Function() onListen): Stream<T> - added:
method DoExtensions.doOnPause(void Function(Future<dynamic> resumeSignal) onPause): Stream<T> - added:
method DoExtensions.doOnResume(void Function() onResume): Stream<T> - added:
method ExhaustMapExtension.exhaustMap<S>(Stream<S> Function(T value) mapper): Stream<S> - added:
method FlatMapExtension.flatMap<S>(Stream<S> Function(T value) mapper): Stream<S> - added:
method FlatMapExtension.flatMapIterable<S>(Stream<Iterable<S>> Function(T value) mapper): Stream<S> - added:
method GroupByExtension.groupBy<S>(S Function(T value) grouper): Stream<GroupByStream<T, S>> - added:
method IgnoreElementsExtension.ignoreElements(): Stream<T> - added:
method IntervalExtension.interval(Duration duration): Stream<T> - added:
method MapToExtension.mapTo<S>(S value): Stream<S> - added:
method MaterializeExtension.materialize(): Stream<Notification<T>> - added:
method MaxExtension.max([Comparator<T> comparator]): Future<T> - added:
method MergeExtension.mergeWith(Iterable<Stream<T>> streams): Stream<T> - added:
method MinExtension.min([Comparator<T> comparator]): Future<T> - added:
method OnErrorExtensions.onErrorResume(Stream<T> Function(dynamic error) recoveryFn): Stream<T> - added:
method OnErrorExtensions.onErrorResumeNext(Stream<T> recoveryStream): Stream<T> - added:
method OnErrorExtensions.onErrorReturn(T returnValue): Stream<T> - added:
method OnErrorExtensions.onErrorReturnWith(T Function(dynamic error) returnFn): Stream<T> - added:
method PairwiseExtension.pairwise(): Stream<Iterable<T>> - added:
method PublishConnectableStream.autoConnect({ void Function(StreamSubscription<T> subscription) connection, }): Stream<T> - added:
method PublishConnectableStream.connect(): StreamSubscription<T> - added:
method PublishConnectableStream.refCount(): Stream<T> - added:
method ReplayConnectableStream.autoConnect({ void Function(StreamSubscription<T> subscription) connection, }): ReplayStream<T> - added:
method ReplayConnectableStream.connect(): StreamSubscription<T> - added:
method ReplayConnectableStream.refCount(): ReplayStream<T> - added:
method SampleExtensions.sample(Stream<dynamic> sampleStream): Stream<T> - added:
method SampleExtensions.sampleTime(Duration duration): Stream<T> - added:
method ScanExtension.scan<S>( S Function(S accumulated, T value, int index) accumulator, [ S seed, ]): Stream<S> - added:
method SkipUntilExtension.skipUntil<S>(Stream<S> otherStream): Stream<T> - added:
method StartWithExtension.startWith(T startValue): Stream<T> - added:
method StartWithManyExtension.startWithMany(List<T> startValues): Stream<T> - added:
method SwitchIfEmptyExtension.switchIfEmpty(Stream<T> fallbackStream): Stream<T> - added:
method SwitchMapExtension.switchMap<S>(Stream<S> Function(T value) mapper): Stream<S> - added:
method TakeUntilExtension.takeUntil<S>(Stream<S> otherStream): Stream<T> - added:
method ThrottleExtensions.throttle(Stream Function(T event) window, {bool trailing = …}): Stream<T> - added:
method ThrottleExtensions.throttleTime(Duration duration, {bool trailing = …}): Stream<T> - added:
method TimeIntervalExtension.timeInterval(): Stream<TimeInterval<T>> - added:
method TimeStampExtension.timestamp(): Stream<Timestamped<T>> - added:
method ValueConnectableStream.autoConnect({ void Function(StreamSubscription<T> subscription) connection, }): ValueStream<T> - added:
method ValueConnectableStream.connect(): StreamSubscription<T> - added:
method ValueConnectableStream.refCount(): ValueStream<T> - added:
method WhereTypeExtension.whereType<S>(): Stream<S> - added:
method WindowExtensions.window(Stream window): Stream<Stream<T>> - added:
method WindowExtensions.windowCount(int count, [int startBufferEvery = …]): Stream<Stream<T>> - added:
method WindowExtensions.windowTest(bool Function(T event) onTestHandler): Stream<Stream<T>> - added:
method WindowExtensions.windowTime(Duration duration): Stream<Stream<T>> - added:
method WithLatestFromExtensions.withLatestFrom2<A, B, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, R Function(T t, A a, B b) fn, ): Stream<R> - added:
method WithLatestFromExtensions.withLatestFrom3<A, B, C, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, R Function(T t, A a, B b, C c) fn, ): Stream<R> - added:
method WithLatestFromExtensions.withLatestFrom4<A, B, C, D, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, R Function(T t, A a, B b, C c, D d) fn, ): Stream<R> - added:
method WithLatestFromExtensions.withLatestFrom5<A, B, C, D, E, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, R Function(T t, A a, B b, C c, D d, E e) fn, ): Stream<R> - added:
method WithLatestFromExtensions.withLatestFrom6<A, B, C, D, E, F, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, R Function(T t, A a, B b, C c, D d, E e, F f) fn, ): Stream<R> - added:
method WithLatestFromExtensions.withLatestFrom7<A, B, C, D, E, F, G, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, Stream<G> latestFromStream7, R Function(T t, A a, B b, C c, D d, E e, F f, G g) fn, ): Stream<R> - added:
method WithLatestFromExtensions.withLatestFrom8<A, B, C, D, E, F, G, H, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, Stream<G> latestFromStream7, Stream<H> latestFromStream8, R Function(T t, A a, B b, C c, D d, E e, F f, G g, H h) fn, ): Stream<R> - added:
method WithLatestFromExtensions.withLatestFrom9<A, B, C, D, E, F, G, H, I, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, Stream<G> latestFromStream7, Stream<H> latestFromStream8, Stream<I> latestFromStream9, R Function(T t, A a, B b, C c, D d, E e, F f, G g, H h, I i… - added:
method WithLatestFromExtensions.withLatestFrom<S, R>( Stream<S> latestFromStream, R Function(T t, S s) fn): Stream<R> - added:
method WithLatestFromExtensions.withLatestFromList(Iterable<Stream<T>> latestFromStreams): Stream<List<T>> - added:
method ZipWithExtension.zipWith<S, R>(Stream<S> other, R Function(T t, S s) zipper): Stream<R> - added:
static method Rx.combineLatest2<A, B, T>(Stream<A> streamA, Stream<B> streamB, T Function(A a, B b) combiner): Stream<T> - added:
static method Rx.combineLatest3<A, B, C, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, T Function(A a, B b, C c) combiner): Stream<T> - added:
static method Rx.combineLatest4<A, B, C, D, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, T Function(A a, B b, C c, D d) combiner): Stream<T> - added:
static method Rx.combineLatest5<A, B, C, D, E, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, T Function(A a, B b, C c, D d, E e) combiner): Stream<T> - added:
static method Rx.combineLatest6<A, B, C, D, E, F, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, T Function(A a, B b, C c, D d, E e, F f) combiner): Stream<T> - added:
static method Rx.combineLatest7<A, B, C, D, E, F, G, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, T Function(A a, B b, C c, D d, E e, F f, G g) combiner): Stream<T> - added:
static method Rx.combineLatest8<A, B, C, D, E, F, G, H, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, T Function(A a, B b, C c, D d, E e, F f, G g, H h) combiner): Stream<T> - added:
static method Rx.combineLatest9<A, B, C, D, E, F, G, H, I, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, Stream<I> streamI, T Function(A a, B b, C c, D d, E e, F f, G g, H h, I i) combiner): Stream<T> - added:
static method Rx.combineLatest<T, R>( Iterable<Stream<T>> streams, R Function(List<T> values) combiner): Stream<R> - added:
static method Rx.combineLatestList<T>(Iterable<Stream<T>> streams): Stream<List<T>> - added:
static method Rx.concat<T>(Iterable<Stream<T>> streams): Stream<T> - added:
static method Rx.concatEager<T>(Iterable<Stream<T>> streams): Stream<T> - added:
static method Rx.defer<T>(Stream<T> Function() streamFactory, {bool reusable = …}): Stream<T> - added:
static method Rx.forkJoin2<A, B, T>(Stream<A> streamA, Stream<B> streamB, T Function(A a, B b) combiner): Stream<T> - added:
static method Rx.forkJoin3<A, B, C, T>(Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, T Function(A a, B b, C c) combiner): Stream<T> - added:
static method Rx.forkJoin4<A, B, C, D, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, T Function(A a, B b, C c, D d) combiner): Stream<T> - added:
static method Rx.forkJoin5<A, B, C, D, E, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, T Function(A a, B b, C c, D d, E e) combiner): Stream<T> - added:
static method Rx.forkJoin6<A, B, C, D, E, F, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, T Function(A a, B b, C c, D d, E e, F f) combiner): Stream<T> - added:
static method Rx.forkJoin7<A, B, C, D, E, F, G, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, T Function(A a, B b, C c, D d, E e, F f, G g) combiner): Stream<T> - added:
static method Rx.forkJoin8<A, B, C, D, E, F, G, H, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, T Function(A a, B b, C c, D d, E e, F f, G g, H h) combiner): Stream<T> - added:
static method Rx.forkJoin9<A, B, C, D, E, F, G, H, I, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, Stream<I> streamI, T Function(A a, B b, C c, D d, E e, F f, G g, H h, I i) combiner): Stream<T> - added:
static method Rx.forkJoin<T, R>( Iterable<Stream<T>> streams, R Function(List<T> values) combiner): Stream<R> - added:
static method Rx.forkJoinList<T>(Iterable<Stream<T>> streams): Stream<List<T>> - added:
static method Rx.merge<T>(Iterable<Stream<T>> streams): Stream<T> - added:
static method Rx.never<T>(): Stream<T> - added:
static method Rx.race<T>(Iterable<Stream<T>> streams): Stream<T> - added:
static method Rx.range(int startInclusive, int endInclusive): Stream<int> - added:
static method Rx.repeat<T>(Stream<T> Function(int repeatIndex) streamFactory, [int count]): Stream<T> - added:
static method Rx.retry<T>(Stream<T> Function() streamFactory, [int count]): Stream<T> - added:
static method Rx.retryWhen<T>( Stream<T> Function() streamFactory, Stream<void> Function(dynamic error, StackTrace stack) retryWhenFactory, ): Stream<T> - added:
static method Rx.sequenceEqual<A, B>(Stream<A> stream, Stream<B> other, {bool Function(A a, B b) equals}): Stream<bool> - added:
static method Rx.switchLatest<T>(Stream<Stream<T>> streams): Stream<T> - added:
static method Rx.timer<T>(T value, Duration duration): Stream<T> - added:
static method Rx.zip2<A, B, T>( Stream<A> streamA, Stream<B> streamB, T Function(A a, B b) zipper): Stream<T> - added:
static method Rx.zip3<A, B, C, T>(Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, T Function(A a, B b, C c) zipper): Stream<T> - added:
static method Rx.zip4<A, B, C, D, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, T Function(A a, B b, C c, D d) zipper): Stream<T> - added:
static method Rx.zip5<A, B, C, D, E, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, T Function(A a, B b, C c, D d, E e) zipper): Stream<T> - added:
static method Rx.zip6<A, B, C, D, E, F, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, T Function(A a, B b, C c, D d, E e, F f) zipper): Stream<T> - added:
static method Rx.zip7<A, B, C, D, E, F, G, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, T Function(A a, B b, C c, D d, E e, F f, G g) zipper): Stream<T> - added:
static method Rx.zip8<A, B, C, D, E, F, G, H, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, T Function(A a, B b, C c, D d, E e, F f, G g, H h) zipper): Stream<T> - added:
static method Rx.zip9<A, B, C, D, E, F, G, H, I, T>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, Stream<I> streamI, T Function(A a, B b, C c, D d, E e, F f, G g, H h, I i) zipper): Stream<T> - added:
static method Rx.zip<T, R>( Iterable<Stream<T>> streams, R Function(List<T> values) zipper): Stream<R> - added:
static method Rx.zipList<T>(Iterable<Stream<T>> streams): Stream<List<T>>
- removed:
class ErrorStream<T> extends Stream<T> - removed:
ctor ErrorStream(this.error) - removed:
field ErrorStream.error: final Object - removed:
method ErrorStream.listen(void onData(T event), {Function onError, void onDone(), bool cancelOnError}): StreamSubscription<T> - changed:
ctor CombineLatestStream( Iterable<Stream<T>> streams, R combiner(List<T> values), ) → ctor CombineLatestStream( Iterable<Stream<T>> streams, R Function(List<T> values) combiner, ) - changed:
ctor DeferStream(Stream<T> streamFactory(), {bool reusable = …}) → ctor DeferStream(Stream<T> Function() streamFactory, {bool reusable = …}) - changed:
ctor ForkJoinStream( Iterable<Stream<T>> streams, R combiner(List<T> values), ) → ctor ForkJoinStream( Iterable<Stream<T>> streams, R Function(List<T> values) combiner, ) - changed:
ctor SequenceEqualStream(Stream<S> stream, Stream<T> other, {bool equals(S s, T t)}) → ctor SequenceEqualStream(Stream<S> stream, Stream<T> other, {bool Function(S s, T t) equals}) - changed:
ctor ZipStream( Iterable<Stream<T>> streams, R zipper(List<T> values), ) → ctor ZipStream( Iterable<Stream<T>> streams, R Function(List<T> values) zipper, ) - changed:
method ConcatEagerStream.listen(void onData(T event), {Function onError, void onDone(), bool cancelOnError}): StreamSubscription<T> → method ConcatEagerStream.listen(void Function(T event) onData, {Function onError, void Function() onDone, bool cancelOnError}): StreamSubscription<T> - changed:
method ConcatStream.listen(void onData(T event), {Function onError, void onDone(), bool cancelOnError}): StreamSubscription<T> → method ConcatStream.listen( void Function(T event) onData, { Function onError, void Function() onDone, bool cancelOnError, }): StreamSubscription<T> - changed:
method DeferStream.listen(void onData(T event), {Function onError, void onDone(), bool cancelOnError}): StreamSubscription<T> → method DeferStream.listen(void Function(T event) onData, {Function onError, void Function() onDone, bool cancelOnError}): StreamSubscription<T> - changed:
method MergeStream.listen(void onData(T event), {Function onError, void onDone(), bool cancelOnError}): StreamSubscription<T> → method MergeStream.listen(void Function(T event) onData, {Function onError, void Function() onDone, bool cancelOnError}): StreamSubscription<T> - changed:
method NeverStream.listen(void onData(T event), {Function onError, void onDone(), bool cancelOnError}): StreamSubscription<T> → method NeverStream.listen(void Function(T event) onData, {Function onError, void Function() onDone, bool cancelOnError}): StreamSubscription<T> - changed:
method RaceStream.listen(void onData(T event), {Function onError, void onDone(), bool cancelOnError}): StreamSubscription<T> → method RaceStream.listen(void Function(T event) onData, {Function onError, void Function() onDone, bool cancelOnError}): StreamSubscription<T> - changed:
method RangeStream.listen(void onData(int event), {Function onError, void onDone(), bool cancelOnError}): StreamSubscription<int> → method RangeStream.listen(void Function(int event) onData, {Function onError, void Function() onDone, bool cancelOnError}): StreamSubscription<int> - changed:
method RepeatStream.listen( void onData(T event), { Function onError, void onDone(), bool cancelOnError, }): StreamSubscription<T> → method RepeatStream.listen( void Function(T event) onData, { Function onError, void Function() onDone, bool cancelOnError, }): StreamSubscription<T> - changed:
method RetryStream.listen( void onData(T event), { Function onError, void onDone(), bool cancelOnError, }): StreamSubscription<T> → method RetryStream.listen( void Function(T event) onData, { Function onError, void Function() onDone, bool cancelOnError, }): StreamSubscription<T> - changed:
method RetryWhenStream.listen( void onData(T event), { Function onError, void onDone(), bool cancelOnError, }): StreamSubscription<T> → method RetryWhenStream.listen( void Function(T event) onData, { Function onError, void Function() onDone, bool cancelOnError, }): StreamSubscription<T> - changed:
method SequenceEqualStream.listen(void onData(bool event), {Function onError, void onDone(), bool cancelOnError}): StreamSubscription<bool> → method SequenceEqualStream.listen(void Function(bool event) onData, {Function onError, void Function() onDone, bool cancelOnError}): StreamSubscription<bool> - changed:
method SwitchLatestStream.listen( void onData(T event), { Function onError, void onDone(), bool cancelOnError, }): StreamSubscription<T> → method SwitchLatestStream.listen( void Function(T event) onData, { Function onError, void Function() onDone, bool cancelOnError, }): StreamSubscription<T> - changed:
static method CombineLatestStream.combine2<A, B, R>( Stream<A> streamOne, Stream<B> streamTwo, R combiner(A a, B b), ): CombineLatestStream<dynamic, R> → static method CombineLatestStream.combine2<A, B, R>( Stream<A> streamOne, Stream<B> streamTwo, R Function(A a, B b) combiner, ): CombineLatestStream<dynamic, R> - changed:
static method CombineLatestStream.combine3<A, B, C, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, R combiner(A a, B b, C c), ): CombineLatestStream<dynamic, R> → static method CombineLatestStream.combine3<A, B, C, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, R Function(A a, B b, C c) combiner, ): CombineLatestStream<dynamic, R> - changed:
static method CombineLatestStream.combine4<A, B, C, D, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, R combiner(A a, B b, C c, D d), ): CombineLatestStream<dynamic, R> → static method CombineLatestStream.combine4<A, B, C, D, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, R Function(A a, B b, C c, D d) combiner, ): CombineLatestStream<dynamic, R> - changed:
static method CombineLatestStream.combine5<A, B, C, D, E, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, R combiner(A a, B b, C c, D d, E e), ): CombineLatestStream<dynamic, R> → static method CombineLatestStream.combine5<A, B, C, D, E, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, R Function(A a, B b, C c, D d, E e) combiner, ): CombineLatestStream<dynamic, R> - changed:
static method CombineLatestStream.combine6<A, B, C, D, E, F, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, R combiner(A a, B b, C c, D d, E e, F f), ): CombineLatestStream<dynamic, R> → static method CombineLatestStream.combine6<A, B, C, D, E, F, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, R Function(A a, B b, C c, D d, E e, F f) combiner, ): CombineLatestStream<dynamic, R> - changed:
static method CombineLatestStream.combine7<A, B, C, D, E, F, G, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, R combiner(A a, B b, C c, D d, E e, F f, G g), ): CombineLatestStream<dynamic, R> → static method CombineLatestStream.combine7<A, B, C, D, E, F, G, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, R Function(A a, B b, C c, D d, E e, F f, G g) combiner, ): CombineLatestStream<dynamic, R> - changed:
static method CombineLatestStream.combine8<A, B, C, D, E, F, G, H, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, R combiner(A a, B b, C c, D d, E e, F f, G g, H h), ): CombineLatestStream<dynamic, R> → static method CombineLatestStream.combine8<A, B, C, D, E, F, G, H, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, R Function(A a, B b, C c, D d, E e, F f, G g, H h) combiner, ): CombineLatestStream<dynamic, R> - changed:
static method CombineLatestStream.combine9<A, B, C, D, E, F, G, H, I, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, Stream<I> streamI, R combiner(A a, B b, C c, D d, E e, F f, G g, H h, I i), ): CombineLatestStream<dynamic, R> → static method CombineLatestStream.combine9<A, B, C, D, E, F, G, H, I, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, Stream<I> streamI, R Function(A a, B b, C c, D d, E e, F f, G g, H h, I i) combiner, ): CombineLatestStream<dynamic, R> - changed:
static method ForkJoinStream.combine2<A, B, R>( Stream<A> streamOne, Stream<B> streamTwo, R combiner(A a, B b), ): ForkJoinStream<dynamic, R> → static method ForkJoinStream.combine2<A, B, R>( Stream<A> streamOne, Stream<B> streamTwo, R Function(A a, B b) combiner, ): ForkJoinStream<dynamic, R> - changed:
static method ForkJoinStream.combine3<A, B, C, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, R combiner(A a, B b, C c), ): ForkJoinStream<dynamic, R> → static method ForkJoinStream.combine3<A, B, C, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, R Function(A a, B b, C c) combiner, ): ForkJoinStream<dynamic, R> - changed:
static method ForkJoinStream.combine4<A, B, C, D, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, R combiner(A a, B b, C c, D d), ): ForkJoinStream<dynamic, R> → static method ForkJoinStream.combine4<A, B, C, D, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, R Function(A a, B b, C c, D d) combiner, ): ForkJoinStream<dynamic, R> - changed:
static method ForkJoinStream.combine5<A, B, C, D, E, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, R combiner(A a, B b, C c, D d, E e), ): ForkJoinStream<dynamic, R> → static method ForkJoinStream.combine5<A, B, C, D, E, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, R Function(A a, B b, C c, D d, E e) combiner, ): ForkJoinStream<dynamic, R> - changed:
static method ForkJoinStream.combine6<A, B, C, D, E, F, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, R combiner(A a, B b, C c, D d, E e, F f), ): ForkJoinStream<dynamic, R> → static method ForkJoinStream.combine6<A, B, C, D, E, F, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, R Function(A a, B b, C c, D d, E e, F f) combiner, ): ForkJoinStream<dynamic, R> - changed:
static method ForkJoinStream.combine7<A, B, C, D, E, F, G, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, R combiner(A a, B b, C c, D d, E e, F f, G g), ): ForkJoinStream<dynamic, R> → static method ForkJoinStream.combine7<A, B, C, D, E, F, G, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, R Function(A a, B b, C c, D d, E e, F f, G g) combiner, ): ForkJoinStream<dynamic, R> - changed:
static method ForkJoinStream.combine8<A, B, C, D, E, F, G, H, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, R combiner(A a, B b, C c, D d, E e, F f, G g, H h), ): ForkJoinStream<dynamic, R> → static method ForkJoinStream.combine8<A, B, C, D, E, F, G, H, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, R Function(A a, B b, C c, D d, E e, F f, G g, H h) combiner, ): ForkJoinStream<dynamic, R> - changed:
static method ForkJoinStream.combine9<A, B, C, D, E, F, G, H, I, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, Stream<I> streamI, R combiner(A a, B b, C c, D d, E e, F f, G g, H h, I i), ): ForkJoinStream<dynamic, R> → static method ForkJoinStream.combine9<A, B, C, D, E, F, G, H, I, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, Stream<I> streamI, R Function(A a, B b, C c, D d, E e, F f, G g, H h, I i) combiner, ): ForkJoinStream<dynamic, R> - changed:
static method ZipStream.zip2<A, B, R>( Stream<A> streamOne, Stream<B> streamTwo, R zipper(A a, B b), ): ZipStream<dynamic, R> → static method ZipStream.zip2<A, B, R>( Stream<A> streamOne, Stream<B> streamTwo, R Function(A a, B b) zipper, ): ZipStream<dynamic, R> - changed:
static method ZipStream.zip3<A, B, C, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, R zipper(A a, B b, C c), ): ZipStream<dynamic, R> → static method ZipStream.zip3<A, B, C, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, R Function(A a, B b, C c) zipper, ): ZipStream<dynamic, R> - changed:
static method ZipStream.zip4<A, B, C, D, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, R zipper(A a, B b, C c, D d), ): ZipStream<dynamic, R> → static method ZipStream.zip4<A, B, C, D, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, R Function(A a, B b, C c, D d) zipper, ): ZipStream<dynamic, R> - changed:
static method ZipStream.zip5<A, B, C, D, E, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, R zipper(A a, B b, C c, D d, E e), ): ZipStream<dynamic, R> → static method ZipStream.zip5<A, B, C, D, E, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, R Function(A a, B b, C c, D d, E e) zipper, ): ZipStream<dynamic, R> - changed:
static method ZipStream.zip6<A, B, C, D, E, F, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, R zipper(A a, B b, C c, D d, E e, F f), ): ZipStream<dynamic, R> → static method ZipStream.zip6<A, B, C, D, E, F, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, R Function(A a, B b, C c, D d, E e, F f) zipper, ): ZipStream<dynamic, R> - changed:
static method ZipStream.zip7<A, B, C, D, E, F, G, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, R zipper(A a, B b, C c, D d, E e, F f, G g), ): ZipStream<dynamic, R> → static method ZipStream.zip7<A, B, C, D, E, F, G, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, R Function(A a, B b, C c, D d, E e, F f, G g) zipper, ): ZipStream<dynamic, R> - changed:
static method ZipStream.zip8<A, B, C, D, E, F, G, H, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, R zipper(A a, B b, C c, D d, E e, F f, G g, H h), ): ZipStream<dynamic, R> → static method ZipStream.zip8<A, B, C, D, E, F, G, H, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, R Function(A a, B b, C c, D d, E e, F f, G g, H h) zipper, ): ZipStream<dynamic, R> - changed:
static method ZipStream.zip9<A, B, C, D, E, F, G, H, I, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, Stream<I> streamI, R zipper(A a, B b, C c, D d, E e, F f, G g, H h, I i), ): ZipStream<dynamic, R> → static method ZipStream.zip9<A, B, C, D, E, F, G, H, I, R>( Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, Stream<G> streamG, Stream<H> streamH, Stream<I> streamI, R Function(A a, B b, C c, D d, E e, F f, G g, H h, I i) zipper, ): ZipStream<dynamic, R> - added:
class ConnectableStream<T>: abstract extends StreamView<T> - added:
class ConnectableStreamSubscription<T> extends StreamSubscription<T> - added:
class PublishConnectableStream<T> extends ConnectableStream<T> - added:
class ReplayConnectableStream<T> extends ConnectableStream<T> implements ReplayStream<T> - added:
class ReplayStream<T>: abstract implements Stream<T> - added:
class ValueConnectableStream<T> extends ConnectableStream<T> implements ValueStream<T> - added:
class ValueStream<T>: abstract implements Stream<T> - added:
ctor ConnectableStream(Stream<T> stream) - added:
ctor ConnectableStreamSubscription(this._source, this._subject) - added:
ctor PublishConnectableStream(Stream<T> source) - added:
ctor ReplayConnectableStream(Stream<T> stream, {int maxSize}) - added:
ctor ValueConnectableStream(Stream<T> source) - added:
ctor ValueConnectableStream.seeded( Stream<T> source, T seedValue, ) - added:
extension ConcatExtensions<T> on Stream<T> - added:
extension ConnectableStreamExtensions<T> on Stream<T> - added:
extension MergeExtension<T> on Stream<T> - added:
extension ZipWithExtension<T> on Stream<T> - added:
get ConnectableStreamSubscription.isPaused: bool - added:
get ReplayConnectableStream.values: List<T> - added:
get ReplayStream.values: List<T> - added:
get ValueConnectableStream.hasValue: bool - added:
get ValueConnectableStream.value: T - added:
get ValueStream.hasValue: bool - added:
get ValueStream.value: T - added:
method ConcatExtensions.concatWith(Iterable<Stream<T>> other): Stream<T> - added:
method ConnectableStream.autoConnect({ void Function(StreamSubscription<T> subscription) connection, }): Stream<T> - added:
method ConnectableStream.connect(): StreamSubscription<T> - added:
method ConnectableStream.refCount(): Stream<T> - added:
method ConnectableStreamExtensions.publish(): ConnectableStream<T> - added:
method ConnectableStreamExtensions.publishReplay({int maxSize}): ReplayConnectableStream<T> - added:
method ConnectableStreamExtensions.publishValue(): ValueConnectableStream<T> - added:
method ConnectableStreamExtensions.publishValueSeeded(T seedValue): ValueConnectableStream<T> - added:
method ConnectableStreamExtensions.share(): Stream<T> - added:
method ConnectableStreamExtensions.shareReplay({int maxSize}): ReplayStream<T> - added:
method ConnectableStreamExtensions.shareValue(): ValueStream<T> - added:
method ConnectableStreamExtensions.shareValueSeeded(T seedValue): ValueStream<T> - added:
method ConnectableStreamSubscription.asFuture<E>([E futureValue]): Future<E> - added:
method ConnectableStreamSubscription.cancel(): Future<dynamic> - added:
method ConnectableStreamSubscription.onData(void Function(T data) handleData): void - added:
method ConnectableStreamSubscription.onDone(void Function() handleDone): void - added:
method ConnectableStreamSubscription.onError(Function handleError): void - added:
method ConnectableStreamSubscription.pause([Future<dynamic> resumeSignal]): void - added:
method ConnectableStreamSubscription.resume(): void - added:
method MergeExtension.mergeWith(Iterable<Stream<T>> streams): Stream<T> - added:
method PublishConnectableStream.autoConnect({ void Function(StreamSubscription<T> subscription) connection, }): Stream<T> - added:
method PublishConnectableStream.connect(): StreamSubscription<T> - added:
method PublishConnectableStream.refCount(): Stream<T> - added:
method ReplayConnectableStream.autoConnect({ void Function(StreamSubscription<T> subscription) connection, }): ReplayStream<T> - added:
method ReplayConnectableStream.connect(): StreamSubscription<T> - added:
method ReplayConnectableStream.refCount(): ReplayStream<T> - added:
method ValueConnectableStream.autoConnect({ void Function(StreamSubscription<T> subscription) connection, }): ValueStream<T> - added:
method ValueConnectableStream.connect(): StreamSubscription<T> - added:
method ValueConnectableStream.refCount(): ValueStream<T> - added:
method ZipWithExtension.zipWith<S, R>(Stream<S> other, R Function(T t, S s) zipper): Stream<R>
- changed:
class BehaviorSubject<T> extends Subject<T> implements ValueObservable<T> → class BehaviorSubject<T> extends Subject<T> implements ValueStream<T> - changed:
class ReplaySubject<T> extends Subject<T> implements ReplayObservable<T> → class ReplaySubject<T> extends Subject<T> implements ReplayStream<T> - changed:
class Subject<T>: abstract extends Observable<T> implements StreamController<T> → class Subject<T>: abstract extends StreamView<T> implements StreamController<T> - changed:
ctor BehaviorSubject({ void onListen(), void onCancel(), bool sync = …, }) → ctor BehaviorSubject({ void Function() onListen, void Function() onCancel, bool sync = …, }) - changed:
ctor BehaviorSubject.seeded( T seedValue, { void onListen(), void onCancel(), bool sync = …, }) → ctor BehaviorSubject.seeded( T seedValue, { void Function() onListen, void Function() onCancel, bool sync = …, }) - changed:
ctor PublishSubject( {void onListen(), void onCancel(), bool sync = …}) → ctor PublishSubject( {void Function() onListen, void Function() onCancel, bool sync = …}) - changed:
ctor ReplaySubject({ int maxSize, void onListen(), void onCancel(), bool sync = …, }) → ctor ReplaySubject({ int maxSize, void Function() onListen, void Function() onCancel, bool sync = …, }) - changed:
ctor Subject(StreamController<T> controller, Observable<T> observable) → ctor Subject(StreamController<T> controller, Stream<T> stream) - changed:
get BehaviorSubject.stream: ValueObservable<T> → get BehaviorSubject.stream: ValueStream<T> - changed:
get Subject.stream: Observable<T> → get Subject.stream: Stream<T> - changed:
set Subject.onCancel(void onCancelHandler()) → set Subject.onCancel(void Function() onCancelHandler) - changed:
set Subject.onListen(void onListenHandler()) → set Subject.onListen(void Function() onListenHandler) - changed:
set Subject.onPause(void onPauseHandler()) → set Subject.onPause(void Function() onPauseHandler) - changed:
set Subject.onResume(void onResumeHandler()) → set Subject.onResume(void Function() onResumeHandler)
- removed:
class GroupByObservable<T, S> extends Observable<T> - removed:
class OfTypeStreamTransformer<T, S> extends StreamTransformerBase<T, S> - removed:
class TypeToken<S> - removed:
ctor GroupByObservable(this.key, Stream<T> stream) - removed:
ctor OfTypeStreamTransformer(TypeToken<S> typeToken) - removed:
ctor TypeToken() - removed:
field GroupByObservable.key: final S - removed:
method OfTypeStreamTransformer.bind(Stream<T> stream): Stream<S> - removed:
method TypeToken.isType(dynamic other): bool - removed:
method TypeToken.toType(dynamic other): S - removed:
variable kBool: const TypeToken<bool> - removed:
variable kDouble: const TypeToken<double> - removed:
variable kInt: const TypeToken<int> - removed:
variable kNum: const TypeToken<num> - removed:
variable kString: const TypeToken<String> - removed:
variable kSymbol: const TypeToken<Symbol> - changed:
class GroupByStreamTransformer<T, S> extends StreamTransformerBase<T, GroupByObservable<T, S>> → class GroupByStreamTransformer<T, S> extends StreamTransformerBase<T, GroupByStream<T, S>> - changed:
ctor BufferStreamTransformer(Stream window(T event)) → ctor BufferStreamTransformer(Stream Function(T event) window) - changed:
ctor BufferTestStreamTransformer(bool test(T value)) → ctor BufferTestStreamTransformer(bool Function(T value) test) - changed:
ctor DebounceStreamTransformer(Stream window(T event)) → ctor DebounceStreamTransformer(Stream Function(T event) window) - changed:
ctor DistinctUniqueStreamTransformer({bool equals(T e1, T e2), int hashCode(T e)}) → ctor DistinctUniqueStreamTransformer( {bool Function(T e1, T e2) equals, int Function(T e) hashCode}) - changed:
ctor DoStreamTransformer( {void onCancel(), void onData(T event), void onDone(), void onEach(Notification<T> notification), Function onError, void onListen(), void onPause(Future<dynamic> resumeSignal), void onResume()}) → ctor DoStreamTransformer( {dynamic Function() onCancel, void Function(T event) onData, void Function() onDone, void Function(Notification<T> notification) onEach, Function onError, void Function() onListen, void Function(Future<dynamic> resumeSignal) onPause, void Function() onResume}) - changed:
ctor ExhaustMapStreamTransformer(Stream<S> mapper(T value)) → ctor ExhaustMapStreamTransformer(Stream<S> Function(T value) mapper) - changed:
ctor FlatMapStreamTransformer(Stream<S> mapper(T value)) → ctor FlatMapStreamTransformer(Stream<S> Function(T value) mapper) - changed:
ctor GroupByStreamTransformer(S grouper(T event)) → ctor GroupByStreamTransformer(S Function(T event) grouper) - changed:
ctor SampleStreamTransformer(Stream window(T event)) → ctor SampleStreamTransformer(Stream Function(T event) window) - changed:
ctor ScanStreamTransformer(S accumulator(S accumulated, T value, int index), [S seed]) → ctor ScanStreamTransformer( S Function(S accumulated, T value, int index) accumulator, [S seed]) - changed:
ctor SwitchMapStreamTransformer(Stream<S> mapper(T value)) → ctor SwitchMapStreamTransformer(Stream<S> Function(T value) mapper) - changed:
ctor ThrottleStreamTransformer(Stream window(T event), {bool trailing = …}) → ctor ThrottleStreamTransformer( Stream Function(T event) window, { bool trailing = …, }) - changed:
ctor WindowStreamTransformer(Stream window(T event)) → ctor WindowStreamTransformer(Stream Function(T event) window) - changed:
ctor WindowTestStreamTransformer(bool test(T value)) → ctor WindowTestStreamTransformer(bool Function(T value) test) - changed:
ctor WithLatestFromStreamTransformer( Iterable<Stream<S>> latestFromStreams, R fn(T t, List<S> values)) → ctor WithLatestFromStreamTransformer( Iterable<Stream<S>> latestFromStreams, R Function(T t, List<S> values) fn) - changed:
method GroupByStreamTransformer.bind(Stream<T> stream): Stream<GroupByObservable<T, S>> → method GroupByStreamTransformer.bind(Stream<T> stream): Stream<GroupByStream<T, S>> - changed:
static method WithLatestFromStreamTransformer.with1<T, S, R>( Stream<S> latestFromStream, R fn(T t, S s), ): WithLatestFromStreamTransformer<T, S, R> → static method WithLatestFromStreamTransformer.with1<T, S, R>( Stream<S> latestFromStream, R Function(T t, S s) fn, ): WithLatestFromStreamTransformer<T, S, R> - changed:
static method WithLatestFromStreamTransformer.with2<T, A, B, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, R fn(T t, A a, B b), ): WithLatestFromStreamTransformer<T, dynamic, R> → static method WithLatestFromStreamTransformer.with2<T, A, B, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, R Function(T t, A a, B b) fn, ): WithLatestFromStreamTransformer<T, dynamic, R> - changed:
static method WithLatestFromStreamTransformer.with3<T, A, B, C, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, R fn(T t, A a, B b, C c), ): WithLatestFromStreamTransformer<T, dynamic, R> → static method WithLatestFromStreamTransformer.with3<T, A, B, C, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, R Function(T t, A a, B b, C c) fn, ): WithLatestFromStreamTransformer<T, dynamic, R> - changed:
static method WithLatestFromStreamTransformer.with4<T, A, B, C, D, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, R fn(T t, A a, B b, C c, D d), ): WithLatestFromStreamTransformer<T, dynamic, R> → static method WithLatestFromStreamTransformer.with4<T, A, B, C, D, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, R Function(T t, A a, B b, C c, D d) fn, ): WithLatestFromStreamTransformer<T, dynamic, R> - changed:
static method WithLatestFromStreamTransformer.with5<T, A, B, C, D, E, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, R fn(T t, A a, B b, C c, D d, E e), ): WithLatestFromStreamTransformer<T, dynamic, R> → static method WithLatestFromStreamTransformer.with5<T, A, B, C, D, E, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, R Function(T t, A a, B b, C c, D d, E e) fn, ): WithLatestFromStreamTransformer<T, dynamic, R> - changed:
static method WithLatestFromStreamTransformer.with6<T, A, B, C, D, E, F, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, R fn(T t, A a, B b, C c, D d, E e, F f), ): WithLatestFromStreamTransformer<T, dynamic, R> → static method WithLatestFromStreamTransformer.with6<T, A, B, C, D, E, F, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, R Function(T t, A a, B b, C c, D d, E e, F f) fn, ): WithLatestFromStreamTransformer<T, dynamic, R> - changed:
static method WithLatestFromStreamTransformer.with7<T, A, B, C, D, E, F, G, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, Stream<G> latestFromStream7, R fn(T t, A a, B b, C c, D d, E e, F f, G g), ): WithLatestFromStreamTransformer<T, dynamic, R> → static method WithLatestFromStreamTransformer.with7<T, A, B, C, D, E, F, G, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, Stream<G> latestFromStream7, R Function(T t, A a, B b, C c, D d, E e, F f, G g) fn, ): WithLatestFromStreamTransformer<T, dynamic, R> - changed:
static method WithLatestFromStreamTransformer.with8<T, A, B, C, D, E, F, G, H, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, Stream<G> latestFromStream7, Stream<H> latestFromStream8, R fn(T t, A a, B b, C c, D d, E e, F f, G g, H h), ): WithLatestFromStreamTransforme… → static method WithLatestFromStreamTransformer.with8<T, A, B, C, D, E, F, G, H, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, Stream<G> latestFromStream7, Stream<H> latestFromStream8, R Function(T t, A a, B b, C c, D d, E e, F f, G g, H h) fn, ): WithLatestFromStreamT… - changed:
static method WithLatestFromStreamTransformer.with9<T, A, B, C, D, E, F, G, H, I, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, Stream<G> latestFromStream7, Stream<H> latestFromStream8, Stream<I> latestFromStream9, R fn(T t, A a, B b, C c, D d, E e, F f, G g, H h, I… → static method WithLatestFromStreamTransformer.with9<T, A, B, C, D, E, F, G, H, I, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, Stream<G> latestFromStream7, Stream<H> latestFromStream8, Stream<I> latestFromStream9, R Function(T t, A a, B b, C c, D d, E e, F f, G g, H… - added:
class GroupByStream<T, S> extends StreamView<T> - added:
ctor GroupByStream(this.key, Stream<T> stream) - added:
extension BufferExtensions<T> on Stream<T> - added:
extension DebounceExtensions<T> on Stream<T> - added:
extension DefaultIfEmptyExtension<T> on Stream<T> - added:
extension DelayExtension<T> on Stream<T> - added:
extension DematerializeExtension<T> on Stream<Notification<T>> - added:
extension DistinctUniqueExtension<T> on Stream<T> - added:
extension DoExtensions<T> on Stream<T> - added:
extension ExhaustMapExtension<T> on Stream<T> - added:
extension FlatMapExtension<T> on Stream<T> - added:
extension GroupByExtension<T> on Stream<T> - added:
extension IgnoreElementsExtension<T> on Stream<T> - added:
extension IntervalExtension<T> on Stream<T> - added:
extension MapToExtension<T> on Stream<T> - added:
extension MaterializeExtension<T> on Stream<T> - added:
extension MaxExtension<T> on Stream<T> - added:
extension MinExtension<T> on Stream<T> - added:
extension OnErrorExtensions<T> on Stream<T> - added:
extension PairwiseExtension<T> on Stream<T> - added:
extension SampleExtensions<T> on Stream<T> - added:
extension ScanExtension<T> on Stream<T> - added:
extension SkipUntilExtension<T> on Stream<T> - added:
extension StartWithExtension<T> on Stream<T> - added:
extension StartWithManyExtension<T> on Stream<T> - added:
extension SwitchIfEmptyExtension<T> on Stream<T> - added:
extension SwitchMapExtension<T> on Stream<T> - added:
extension TakeUntilExtension<T> on Stream<T> - added:
extension ThrottleExtensions<T> on Stream<T> - added:
extension TimeIntervalExtension<T> on Stream<T> - added:
extension TimeStampExtension<T> on Stream<T> - added:
extension WhereTypeExtension<T> on Stream<T> - added:
extension WindowExtensions<T> on Stream<T> - added:
extension WithLatestFromExtensions<T> on Stream<T> - added:
field GroupByStream.key: final S - added:
method BufferExtensions.buffer(Stream window): Stream<List<T>> - added:
method BufferExtensions.bufferCount(int count, [int startBufferEvery = …]): Stream<List<T>> - added:
method BufferExtensions.bufferTest(bool Function(T event) onTestHandler): Stream<List<T>> - added:
method BufferExtensions.bufferTime(Duration duration): Stream<List<T>> - added:
method DebounceExtensions.debounce(Stream Function(T event) window): Stream<T> - added:
method DebounceExtensions.debounceTime(Duration duration): Stream<T> - added:
method DefaultIfEmptyExtension.defaultIfEmpty(T defaultValue): Stream<T> - added:
method DelayExtension.delay(Duration duration): Stream<T> - added:
method DematerializeExtension.dematerialize(): Stream<T> - added:
method DistinctUniqueExtension.distinctUnique({ bool Function(T e1, T e2) equals, int Function(T e) hashCode, }): Stream<T> - added:
method DoExtensions.doOnCancel(void Function() onCancel): Stream<T> - added:
method DoExtensions.doOnData(void Function(T event) onData): Stream<T> - added:
method DoExtensions.doOnDone(void Function() onDone): Stream<T> - added:
method DoExtensions.doOnEach(void Function(Notification<T> notification) onEach): Stream<T> - added:
method DoExtensions.doOnError(Function onError): Stream<T> - added:
method DoExtensions.doOnListen(void Function() onListen): Stream<T> - added:
method DoExtensions.doOnPause(void Function(Future<dynamic> resumeSignal) onPause): Stream<T> - added:
method DoExtensions.doOnResume(void Function() onResume): Stream<T> - added:
method ExhaustMapExtension.exhaustMap<S>(Stream<S> Function(T value) mapper): Stream<S> - added:
method FlatMapExtension.flatMap<S>(Stream<S> Function(T value) mapper): Stream<S> - added:
method FlatMapExtension.flatMapIterable<S>(Stream<Iterable<S>> Function(T value) mapper): Stream<S> - added:
method GroupByExtension.groupBy<S>(S Function(T value) grouper): Stream<GroupByStream<T, S>> - added:
method IgnoreElementsExtension.ignoreElements(): Stream<T> - added:
method IntervalExtension.interval(Duration duration): Stream<T> - added:
method MapToExtension.mapTo<S>(S value): Stream<S> - added:
method MaterializeExtension.materialize(): Stream<Notification<T>> - added:
method MaxExtension.max([Comparator<T> comparator]): Future<T> - added:
method MinExtension.min([Comparator<T> comparator]): Future<T> - added:
method OnErrorExtensions.onErrorResume(Stream<T> Function(dynamic error) recoveryFn): Stream<T> - added:
method OnErrorExtensions.onErrorResumeNext(Stream<T> recoveryStream): Stream<T> - added:
method OnErrorExtensions.onErrorReturn(T returnValue): Stream<T> - added:
method OnErrorExtensions.onErrorReturnWith(T Function(dynamic error) returnFn): Stream<T> - added:
method PairwiseExtension.pairwise(): Stream<Iterable<T>> - added:
method SampleExtensions.sample(Stream<dynamic> sampleStream): Stream<T> - added:
method SampleExtensions.sampleTime(Duration duration): Stream<T> - added:
method ScanExtension.scan<S>( S Function(S accumulated, T value, int index) accumulator, [ S seed, ]): Stream<S> - added:
method SkipUntilExtension.skipUntil<S>(Stream<S> otherStream): Stream<T> - added:
method StartWithExtension.startWith(T startValue): Stream<T> - added:
method StartWithManyExtension.startWithMany(List<T> startValues): Stream<T> - added:
method SwitchIfEmptyExtension.switchIfEmpty(Stream<T> fallbackStream): Stream<T> - added:
method SwitchMapExtension.switchMap<S>(Stream<S> Function(T value) mapper): Stream<S> - added:
method TakeUntilExtension.takeUntil<S>(Stream<S> otherStream): Stream<T> - added:
method ThrottleExtensions.throttle(Stream Function(T event) window, {bool trailing = …}): Stream<T> - added:
method ThrottleExtensions.throttleTime(Duration duration, {bool trailing = …}): Stream<T> - added:
method TimeIntervalExtension.timeInterval(): Stream<TimeInterval<T>> - added:
method TimeStampExtension.timestamp(): Stream<Timestamped<T>> - added:
method WhereTypeExtension.whereType<S>(): Stream<S> - added:
method WindowExtensions.window(Stream window): Stream<Stream<T>> - added:
method WindowExtensions.windowCount(int count, [int startBufferEvery = …]): Stream<Stream<T>> - added:
method WindowExtensions.windowTest(bool Function(T event) onTestHandler): Stream<Stream<T>> - added:
method WindowExtensions.windowTime(Duration duration): Stream<Stream<T>> - added:
method WithLatestFromExtensions.withLatestFrom2<A, B, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, R Function(T t, A a, B b) fn, ): Stream<R> - added:
method WithLatestFromExtensions.withLatestFrom3<A, B, C, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, R Function(T t, A a, B b, C c) fn, ): Stream<R> - added:
method WithLatestFromExtensions.withLatestFrom4<A, B, C, D, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, R Function(T t, A a, B b, C c, D d) fn, ): Stream<R> - added:
method WithLatestFromExtensions.withLatestFrom5<A, B, C, D, E, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, R Function(T t, A a, B b, C c, D d, E e) fn, ): Stream<R> - added:
method WithLatestFromExtensions.withLatestFrom6<A, B, C, D, E, F, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, R Function(T t, A a, B b, C c, D d, E e, F f) fn, ): Stream<R> - added:
method WithLatestFromExtensions.withLatestFrom7<A, B, C, D, E, F, G, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, Stream<G> latestFromStream7, R Function(T t, A a, B b, C c, D d, E e, F f, G g) fn, ): Stream<R> - added:
method WithLatestFromExtensions.withLatestFrom8<A, B, C, D, E, F, G, H, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, Stream<G> latestFromStream7, Stream<H> latestFromStream8, R Function(T t, A a, B b, C c, D d, E e, F f, G g, H h) fn, ): Stream<R> - added:
method WithLatestFromExtensions.withLatestFrom9<A, B, C, D, E, F, G, H, I, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, Stream<G> latestFromStream7, Stream<H> latestFromStream8, Stream<I> latestFromStream9, R Function(T t, A a, B b, C c, D d, E e, F f, G g, H h, I i… - added:
method WithLatestFromExtensions.withLatestFrom<S, R>( Stream<S> latestFromStream, R Function(T t, S s) fn): Stream<R> - added:
method WithLatestFromExtensions.withLatestFromList(Iterable<Stream<T>> latestFromStreams): Stream<List<T>>