Skip to content

Upgrading rxdart 0.19 to 0.20

Breaking0.19.0 → 0.20.0Breaking3New4Changed1Fixed2

Full comparisonBack to rxdart
BreakingUpgrade verdict

3 breaking changes.

In plain terms
  • If you used bufferCount with a skip value greater than 1, results were wrong before and are now corrected.
  • Removes deprecated operators bufferWithCount, windowWithCount, amb and flatMapLatest.
  • repeat changed from an operator that replayed the last value to a factory that builds a fresh sequence each cycle.
Must act 3 items need code or config changes

What you must change

Breaking3
bufferCount no longer has buggy behavior when using startBufferEvery (previously skip).
bufferCountstartBufferEveryskip
0.20.0GitHub ReleaseSummarizedView source
Removes deprecated operators bufferWithCount, windowWithCount, amb and flatMapLatest.
bufferWithCountwindowWithCountambflatMapLatest
0.20.0GitHub ReleaseSummarizedView source
repeat is now an Observable factory taking a StreamFactory and count instead of an operator repeating the last event n times.
repeatStreamFactory
0.20.0GitHub ReleaseSummarizedView source

API changes

Generated by DepDelta from published Dart source. Not mixed with prose notes.

  • removed: class RepeatStreamTransformer<T> extends StreamTransformerBase<T, T>
  • removed: ctor Observable.amb(Iterable<Stream<T>> streams)
  • removed: ctor RepeatStreamTransformer(int repeatCount)
  • removed: field CombineLatestStream.controller: final StreamController<T>
  • removed: field RepeatStreamTransformer.transformer: final StreamTransformer<T, T>
  • removed: field ZipStream.controller: final StreamController<T>
  • removed: method CombineLatestStream.listen(void onData(T event), {Function onError, void onDone(), bool cancelOnError}): StreamSubscription<T>
  • removed: method Observable.bufferWithCount(int count, [int skip]): Observable<List<T>>
  • removed: method Observable.flatMapLatest<S>(Stream<S> mapper(T value)): Observable<S>
  • removed: method Observable.repeat(int repeatCount): Observable<T>
  • removed: method Observable.windowWithCount(int count, [int skip]): Observable<Stream<T>>
  • removed: method RepeatStreamTransformer.bind(Stream<T> stream): Stream<T>
  • removed: method ZipStream.listen(void onData(T event), {Function onError, void onDone(), bool cancelOnError}): StreamSubscription<T>
  • removed: static method CombineLatestStream.updateWithValues<T, A, B, C, D, E, F, G, H, I>( T combiner(A a, B b, [C c, D d, E e, F f, G g, H h, I i]), Iterable<dynamic> values, StreamController<T> controller): void
  • removed: static method ZipStream.updateWithValues<T, A, B, C, D, E, F, G, H, I>( T zipper(A a, B b, [C c, D d, E e, F f, G g, H h, I i]), Iterable<dynamic> values, StreamController<T> controller): void
  • changed: class CombineLatestStream<T, A, B, C, D, E, F, G, H, I> extends Stream<T> → class CombineLatestStream<T, R> extends StreamView<R>
  • changed: class ZipStream<T, A, B, C, D, E, F, G, H, I> extends Stream<T> → class ZipStream<T, R> extends StreamView<R>
  • changed: ctor BufferStreamTransformer(this.sampler) → ctor BufferStreamTransformer(this.sampler, {this.exhaustBufferOnDone = …})
  • changed: ctor CombineLatestStream(Iterable<Stream<dynamic>> streams, T combiner(A a, B b, [C c, D d, E e, F f, G g, H h, I i])) → ctor CombineLatestStream( Iterable<Stream<T>> streams, R combiner(List<T> values), )
  • changed: ctor WindowStreamTransformer(this.sampler) → ctor WindowStreamTransformer(this.sampler, {this.exhaustBufferOnDone = …})
  • changed: ctor ZipStream(Iterable<Stream<dynamic>> streams, T zipper(A a, B b, [C c, D d, E e, F f, G g, H h, I i])) → ctor ZipStream( Iterable<Stream<T>> streams, R zipper(List<T> values), )
  • changed: method Observable.bufferCount(int count, [int skip]): Observable<List<T>> → method Observable.bufferCount(int count, [int startBufferEvery = …]): Observable<List<T>>
  • changed: method Observable.windowCount(int count, [int skip]): Observable<Stream<T>> → method Observable.windowCount(int count, [int startBufferEvery = …]): Observable<Stream<T>>
  • changed: static method Observable.combineLatest2<A, B, T>( Stream<A> streamOne, Stream<B> streamTwo, T combiner(A a, B b)): Observable<T> → static method Observable.combineLatest2<A, B, T>( Stream<A> streamA, Stream<B> streamB, T combiner(A a, B b)): Observable<T>
  • changed: static method Observable.combineLatest3<A, B, C, T>( Stream<A> streamOne, Stream<B> streamTwo, Stream<C> streamThree, T combiner(A a, B b, C c)): Observable<T> → 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>
  • changed: static method Observable.combineLatest4<A, B, C, D, T>( Stream<A> streamOne, Stream<B> streamTwo, Stream<C> streamThree, Stream<D> streamFour, T combiner(A a, B b, C c, D d)): Observable<T> → 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>
  • changed: static method Observable.combineLatest5<A, B, C, D, E, T>( Stream<A> streamOne, Stream<B> streamTwo, Stream<C> streamThree, Stream<D> streamFour, Stream<E> streamFive, T combiner(A a, B b, C c, D d, E e)): Observable<T> → 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>
  • changed: static method Observable.combineLatest6<A, B, C, D, E, F, T>( Stream<A> streamOne, Stream<B> streamTwo, Stream<C> streamThree, Stream<D> streamFour, Stream<E> streamFive, Stream<F> streamSix, T combiner(A a, B b, C c, D d, E e, F f)): Observable<T> → 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>
  • changed: static method Observable.combineLatest7<A, B, C, D, E, F, G, T>( Stream<A> streamOne, Stream<B> streamTwo, Stream<C> streamThree, Stream<D> streamFour, Stream<E> streamFive, Stream<F> streamSix, Stream<G> streamSeven, T combiner(A a, B b, C c, D d, E e, F f, G g)): Observable<T> → 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>
  • changed: static method Observable.combineLatest8<A, B, C, D, E, F, G, H, T>( Stream<A> streamOne, Stream<B> streamTwo, Stream<C> streamThree, Stream<D> streamFour, Stream<E> streamFive, Stream<F> streamSix, Stream<G> streamSeven, Stream<H> streamEight, T combiner(A a, B b, C c, D d, E e, F f, G g, H h)): Observable<T> → 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>
  • changed: static method Observable.combineLatest9<A, B, C, D, E, F, G, H, I, T>( Stream<A> streamOne, Stream<B> streamTwo, Stream<C> streamThree, Stream<D> streamFour, Stream<E> streamFive, Stream<F> streamSix, Stream<G> streamSeven, Stream<H> streamEight, Stream<I> streamNine, T combiner(A a, B b, C c, D d, E e, F f, G g, H h, I i)): Observable<T> → 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>
  • changed: static method Observable.zip2<A, B, T>( Stream<A> streamOne, Stream<B> streamTwo, T zipper(A a, B b)): Observable<T> → static method Observable.zip2<A, B, T>( Stream<A> streamA, Stream<B> streamB, T zipper(A a, B b)): Observable<T>
  • changed: static method Observable.zip3<A, B, C, T>( Stream<A> streamOne, Stream<B> streamTwo, Stream<C> streamThree, T zipper(A a, B b, C c)): Observable<T> → 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>
  • changed: static method Observable.zip4<A, B, C, D, T>( Stream<A> streamOne, Stream<B> streamTwo, Stream<C> streamThree, Stream<D> streamFour, T zipper(A a, B b, C c, D d)): Observable<T> → 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>
  • changed: static method Observable.zip5<A, B, C, D, E, T>( Stream<A> streamOne, Stream<B> streamTwo, Stream<C> streamThree, Stream<D> streamFour, Stream<E> streamFive, T zipper(A a, B b, C c, D d, E e)): Observable<T> → 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>
  • changed: static method Observable.zip6<A, B, C, D, E, F, T>( Stream<A> streamOne, Stream<B> streamTwo, Stream<C> streamThree, Stream<D> streamFour, Stream<E> streamFive, Stream<F> streamSix, T zipper(A a, B b, C c, D d, E e, F f)): Observable<T> → 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>
  • changed: static method Observable.zip7<A, B, C, D, E, F, G, T>( Stream<A> streamOne, Stream<B> streamTwo, Stream<C> streamThree, Stream<D> streamFour, Stream<E> streamFive, Stream<F> streamSix, Stream<G> streamSeven, T zipper(A a, B b, C c, D d, E e, F f, G g)): Observable<T> → 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>
  • changed: static method Observable.zip8<A, B, C, D, E, F, G, H, T>( Stream<A> streamOne, Stream<B> streamTwo, Stream<C> streamThree, Stream<D> streamFour, Stream<E> streamFive, Stream<F> streamSix, Stream<G> streamSeven, Stream<H> streamEight, T zipper(A a, B b, C c, D d, E e, F f, G g, H h)): Observable<T> → 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>
  • changed: static method Observable.zip9<A, B, C, D, E, F, G, H, I, T>( Stream<A> streamOne, Stream<B> streamTwo, Stream<C> streamThree, Stream<D> streamFour, Stream<E> streamFive, Stream<F> streamSix, Stream<G> streamSeven, Stream<H> streamEight, Stream<I> streamNine, T zipper(A a, B b, C c, D d, E e, F f, G g, H h, I i)): Observable<T> → 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>
  • added: class CompositeSubscription
  • added: class MapToStreamTransformer<S, T> extends StreamTransformerBase<S, T>
  • added: class RepeatStream<T> extends Stream<T>
  • added: ctor MapToStreamTransformer(T value)
  • added: ctor Observable.repeat(Stream<T> streamFactory(int repeatIndex), [int count])
  • added: ctor RepeatStream(this.streamFactory, [this.count])
  • added: field BufferStreamTransformer.exhaustBufferOnDone: final bool
  • added: field MapToStreamTransformer.transformer: final StreamTransformer<S, T>
  • added: field RepeatStream.controller: StreamController<T>
  • added: field RepeatStream.count: final int
  • added: field RepeatStream.repeatStep: int
  • added: field RepeatStream.subscription: StreamSubscription<T>
  • added: field WindowStreamTransformer.exhaustBufferOnDone: final bool
  • added: get CompositeSubscription.isDisposed: bool
  • added: get DeferStream.isBroadcast: bool
  • added: method CompositeSubscription.add<T>(StreamSubscription<T> subscription): StreamSubscription<T>
  • added: method CompositeSubscription.clear(): void
  • added: method CompositeSubscription.dispose(): void
  • added: method CompositeSubscription.remove(StreamSubscription<dynamic> subscription): void
  • added: method MapToStreamTransformer.bind(Stream<S> stream): Stream<T>
  • added: method Observable.mapTo<S>(S value): Observable<S>
  • added: method Observable.pairwise(): Observable<List<T>>
  • added: method RepeatStream.Function(int): Stream<T>
  • added: method RepeatStream.listen( void onData(T event), { Function onError, void onDone(), bool cancelOnError, }): StreamSubscription<T>
  • added: method RepeatStream.maybeRepeatNext(): void
  • added: method RepeatStream.repeatNext(): void
  • added: static method CombineLatestStream.combine2<A, B, R>( Stream<A> streamOne, Stream<B> streamTwo, R combiner(A a, B b), ): CombineLatestStream<dynamic, R>
  • added: 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>
  • added: 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>
  • added: 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>
  • added: 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>
  • added: 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>
  • added: 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>
  • added: 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>
  • added: static method CombineLatestStream.list<T>( Iterable<Stream<T>> streams, ): CombineLatestStream<T, List<T>>
  • added: static method Observable.combineLatest<T, R>( Iterable<Stream<T>> streams, R combiner(List<T> values)): Observable<R>
  • added: static method Observable.combineLatestList<T>( Iterable<Stream<T>> streams): Observable<List<T>>
  • added: static method Observable.zip<T, R>( Iterable<Stream<T>> streams, R zipper(List<T> values)): Observable<R>
  • added: static method Observable.zipList<T>(Iterable<Stream<T>> streams): Observable<List<T>>
  • added: static method ZipStream.list<T>(Iterable<Stream<T>> streams): ZipStream<T, List<T>>
  • added: static method ZipStream.zip2<A, B, R>( Stream<A> streamOne, Stream<B> streamTwo, R zipper(A a, B b), ): ZipStream<dynamic, R>
  • added: 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>
  • added: 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>
  • added: 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>
  • added: 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>
  • added: 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>
  • added: 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>
  • added: 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>
  • removed: field CombineLatestStream.controller: final StreamController<T>
  • removed: field ZipStream.controller: final StreamController<T>
  • removed: method CombineLatestStream.listen(void onData(T event), {Function onError, void onDone(), bool cancelOnError}): StreamSubscription<T>
  • removed: method ZipStream.listen(void onData(T event), {Function onError, void onDone(), bool cancelOnError}): StreamSubscription<T>
  • removed: static method CombineLatestStream.updateWithValues<T, A, B, C, D, E, F, G, H, I>( T combiner(A a, B b, [C c, D d, E e, F f, G g, H h, I i]), Iterable<dynamic> values, StreamController<T> controller): void
  • removed: static method ZipStream.updateWithValues<T, A, B, C, D, E, F, G, H, I>( T zipper(A a, B b, [C c, D d, E e, F f, G g, H h, I i]), Iterable<dynamic> values, StreamController<T> controller): void
  • changed: class CombineLatestStream<T, A, B, C, D, E, F, G, H, I> extends Stream<T> → class CombineLatestStream<T, R> extends StreamView<R>
  • changed: class ZipStream<T, A, B, C, D, E, F, G, H, I> extends Stream<T> → class ZipStream<T, R> extends StreamView<R>
  • changed: ctor CombineLatestStream(Iterable<Stream<dynamic>> streams, T combiner(A a, B b, [C c, D d, E e, F f, G g, H h, I i])) → ctor CombineLatestStream( Iterable<Stream<T>> streams, R combiner(List<T> values), )
  • changed: ctor ZipStream(Iterable<Stream<dynamic>> streams, T zipper(A a, B b, [C c, D d, E e, F f, G g, H h, I i])) → ctor ZipStream( Iterable<Stream<T>> streams, R zipper(List<T> values), )
  • added: class RepeatStream<T> extends Stream<T>
  • added: ctor RepeatStream(this.streamFactory, [this.count])
  • added: field RepeatStream.controller: StreamController<T>
  • added: field RepeatStream.count: final int
  • added: field RepeatStream.repeatStep: int
  • added: field RepeatStream.subscription: StreamSubscription<T>
  • added: get DeferStream.isBroadcast: bool
  • added: method RepeatStream.Function(int): Stream<T>
  • added: method RepeatStream.listen( void onData(T event), { Function onError, void onDone(), bool cancelOnError, }): StreamSubscription<T>
  • added: method RepeatStream.maybeRepeatNext(): void
  • added: method RepeatStream.repeatNext(): void
  • added: static method CombineLatestStream.combine2<A, B, R>( Stream<A> streamOne, Stream<B> streamTwo, R combiner(A a, B b), ): CombineLatestStream<dynamic, R>
  • added: 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>
  • added: 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>
  • added: 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>
  • added: 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>
  • added: 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>
  • added: 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>
  • added: 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>
  • added: static method CombineLatestStream.list<T>( Iterable<Stream<T>> streams, ): CombineLatestStream<T, List<T>>
  • added: static method ZipStream.list<T>(Iterable<Stream<T>> streams): ZipStream<T, List<T>>
  • added: static method ZipStream.zip2<A, B, R>( Stream<A> streamOne, Stream<B> streamTwo, R zipper(A a, B b), ): ZipStream<dynamic, R>
  • added: 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>
  • added: 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>
  • added: 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>
  • added: 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>
  • added: 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>
  • added: 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>
  • added: 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>
  • removed: class RepeatStreamTransformer<T> extends StreamTransformerBase<T, T>
  • removed: ctor RepeatStreamTransformer(int repeatCount)
  • removed: field RepeatStreamTransformer.transformer: final StreamTransformer<T, T>
  • removed: method RepeatStreamTransformer.bind(Stream<T> stream): Stream<T>
  • changed: ctor BufferStreamTransformer(this.sampler) → ctor BufferStreamTransformer(this.sampler, {this.exhaustBufferOnDone = …})
  • changed: ctor WindowStreamTransformer(this.sampler) → ctor WindowStreamTransformer(this.sampler, {this.exhaustBufferOnDone = …})
  • added: class MapToStreamTransformer<S, T> extends StreamTransformerBase<S, T>
  • added: ctor MapToStreamTransformer(T value)
  • added: field BufferStreamTransformer.exhaustBufferOnDone: final bool
  • added: field MapToStreamTransformer.transformer: final StreamTransformer<S, T>
  • added: field WindowStreamTransformer.exhaustBufferOnDone: final bool
  • added: method MapToStreamTransformer.bind(Stream<S> stream): Stream<T>