Upgrading rxdart 0.21 to 0.22
Breaking0.21.0 → 0.22.6Breaking3Deprecated1New1Fixed9Other4
BreakingUpgrade verdict
3 breaking changes.
In plain terms
- The debounce operator is now two separate operators, so existing code that uses debounce may need updating.
- The sample operator is now two separate operators, so existing code that uses sample may need updating.
- The throttle operator is now two separate operators, so existing code that uses throttle may need updating.
- Use whereType instead of ofType; TypeToken is removed.
Must act 4 items need code or config changes
What you must change
Breaking3
Splits
debounce into debounce and debounceTime.debouncedebounceTimeSplits
sample into sample and sampleTime.samplesampleTimeSplits
throttle into throttle and throttleTime.throttlethrottleTimeDeprecations to plan for
Deprecated1
Deprecates ofType in favor of whereType and drops TypeToken.
ofTypewhereTypeTypeTokenAPI changes
Generated by DepDelta from published Dart source. Not mixed with prose notes.
- removed:
class AmbStream<T> extends Stream<T> - removed:
class FlatMapLatestStreamTransformer<T, S> extends StreamTransformerBase<T, S> - removed:
class OnErrorResumeNextStreamTransformer<T> extends StreamTransformerBase<T, T> - removed:
ctor AmbStream(Iterable<Stream<T>> streams) - removed:
ctor FlatMapLatestStreamTransformer(Stream<S> mapper(T value)) - removed:
ctor OnErrorResumeNextStreamTransformer(Stream<T> recoveryStream) - removed:
ctor RetryError(this.message, this.errors) - removed:
field AmbStream.controller: final StreamController<T> - removed:
field BufferStreamTransformer.exhaustBufferOnDone: final bool - removed:
field BufferStreamTransformer.sampler: final SamplerBuilder<T, List<T>> - removed:
field ConcatEagerStream.controller: final StreamController<T> - removed:
field ConcatStream.controller: final StreamController<T> - removed:
field DebounceStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field DefaultIfEmptyStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field DelayStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field DematerializeStreamTransformer.transformer: final StreamTransformer<Notification<T>, T> - removed:
field DistinctUniqueStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field DoStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field ErrorAndStacktrace.stacktrace: final StackTrace - removed:
field ErrorStream.controller: StreamController<T> - removed:
field ExhaustMapStreamTransformer.transformer: final StreamTransformer<T, S> - removed:
field FlatMapLatestStreamTransformer.transformer: final StreamTransformer<T, S> - removed:
field FlatMapStreamTransformer.transformer: final StreamTransformer<T, S> - removed:
field IgnoreElementsStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field IntervalStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field MapToStreamTransformer.transformer: final StreamTransformer<S, T> - removed:
field MaterializeStreamTransformer.transformer: final StreamTransformer<T, Notification<T>> - removed:
field MergeStream.controller: final StreamController<T> - removed:
field NeverStream.controller: StreamController<T> - removed:
field OfTypeStreamTransformer.transformer: final StreamTransformer<T, S> - removed:
field OnErrorResumeNextStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field OnErrorResumeStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field RaceStream.controller: final StreamController<T> - removed:
field RangeStream.stream: final Stream<int> - removed:
field RepeatStream.controller: StreamController<T> - removed:
field RepeatStream.repeatStep: int - removed:
field RepeatStream.subscription: StreamSubscription<T> - removed:
field RetryStream.controller: StreamController<T> - removed:
field RetryStream.retryStep: int - removed:
field RetryStream.streamFactory: final StreamFactory<T> - removed:
field RetryStream.subscription: StreamSubscription<T> - removed:
field RetryWhenStream.controller: StreamController<T> - removed:
field RetryWhenStream.streamFactory: final StreamFactory<T> - removed:
field RetryWhenStream.subscription: StreamSubscription<T> - removed:
field SampleStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field ScanStreamTransformer.accumulator: final _ScanStreamTransformerAccumulator<T, S> - removed:
field ScanStreamTransformer.seed: final S - removed:
field SkipUntilStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field StartWithManyStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field StartWithStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field Subject.controller: final StreamController<T> - removed:
field SwitchIfEmptyStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field SwitchLatestStream.streams: final Stream<Stream<T>> - removed:
field SwitchMapStreamTransformer.transformer: final StreamTransformer<T, S> - removed:
field TakeUntilStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field ThrottleStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field TimeIntervalStreamTransformer.transformer: final StreamTransformer<T, TimeInterval<T>> - removed:
field TimerStream.controller: final StreamController<T> - removed:
field TimerStream.duration: final Duration - removed:
field TimerStream.value: final T - removed:
field TimestampStreamTransformer.transformer: final StreamTransformer<T, Timestamped<T>> - removed:
field WindowStreamTransformer.exhaustBufferOnDone: final bool - removed:
field WindowStreamTransformer.sampler: final SamplerBuilder<T, Stream<T>> - removed:
field WithLatestFromStreamTransformer.transformer: final StreamTransformer<T, R> - removed:
function Function( Stream<T> stream, OnDataTransform<T, S>, OnDataTransform<S, S>): Stream<S> - removed:
function Function( Stream<T> stream, OnDataTransform<T, S>, OnDataTransform<S, S>, ): Stream<S> - removed:
method AmbStream.listen(void onData(T event), {Function onError, void onDone(), bool cancelOnError}): StreamSubscription<T> - removed:
method BufferStreamTransformer.bind(Stream<T> stream): Stream<List<T>> - removed:
method DebounceStreamTransformer.bind(Stream<T> stream): Stream<T> - removed:
method FlatMapLatestStreamTransformer.bind(Stream<T> stream): Stream<S> - removed:
method GroupByStreamTransformer.Function(T): S - removed:
method Observable.bufferFuture<O>(Future<O> onFutureHandler()): Observable<List<T>> - removed:
method Observable.bufferWhen<O>(Stream<O> other): Observable<List<T>> - removed:
method Observable.windowFuture<O>(Future<O> onFutureHandler()): Observable<Stream<T>> - removed:
method Observable.windowWhen<O>(Stream<O> other): Observable<Stream<T>> - removed:
method OnErrorResumeNextStreamTransformer.bind(Stream<T> stream): Stream<T> - removed:
method RepeatStream.maybeRepeatNext(): void - removed:
method RepeatStream.repeatNext(): void - removed:
method RetryStream.retry(): void - removed:
method RetryWhenStream.retry(): void - removed:
method SampleStreamTransformer.bind(Stream<T> stream): Stream<T> - removed:
method ThrottleStreamTransformer.bind(Stream<T> stream): Stream<T> - removed:
method WindowStreamTransformer.bind(Stream<T> stream): Stream<Stream<T>> - removed:
static method BufferStreamTransformer.assertSampler<T>(SamplerBuilder<T, List<T>> scheduler): void - removed:
static method RangeStream.buildStream(int startInclusive, int endInclusive): Stream<int> - removed:
static method WindowStreamTransformer.assertSampler<T>(SamplerBuilder<T, Stream<T>> scheduler): void - removed:
typedef Future<dynamic> FutureFunc() - removed:
typedef Stream<S> SamplerBuilder<T, S>(Stream<T> stream, OnDataTransform<T, S> bufferHandler, OnDataTransform<S, S> scheduleHandler) - removed:
typedef Stream<T> StreamFactory<T>() - removed:
typedef Stream<void> RetryWhenStreamFactory(dynamic error, StackTrace stack) - removed:
typedef void OnDataTransform<T, S>(T event, EventSink<S> sink, [int skip]) - removed:
typedef void VoidFunc() - changed:
class BufferStreamTransformer<T> extends StreamTransformerBase<T, List<T>> → class BufferStreamTransformer<T> extends BackpressureStreamTransformer<T, List<T>> - changed:
class DebounceStreamTransformer<T> extends StreamTransformerBase<T, T> → class DebounceStreamTransformer<T> extends BackpressureStreamTransformer<T, T> - changed:
class SampleStreamTransformer<T> extends StreamTransformerBase<T, T> → class SampleStreamTransformer<T> extends BackpressureStreamTransformer<T, T> - changed:
class ThrottleStreamTransformer<T> extends StreamTransformerBase<T, T> → class ThrottleStreamTransformer<T> extends BackpressureStreamTransformer<T, T> - changed:
class WindowStreamTransformer<T> extends StreamTransformerBase<T, Stream<T>> → class WindowStreamTransformer<T> extends BackpressureStreamTransformer<T, Stream<T>> - changed:
ctor BufferStreamTransformer(this.sampler, {this.exhaustBufferOnDone = …}) → ctor BufferStreamTransformer(Stream window(T event)) - changed:
ctor DebounceStreamTransformer(Duration duration) → ctor DebounceStreamTransformer(Stream window(T event)) - changed:
ctor DeferStream(this._streamFactory, {bool reusable = …}) → ctor DeferStream(Stream<T> streamFactory(), {bool reusable = …}) - changed:
ctor ErrorAndStacktrace(this.error, this.stacktrace) → ctor ErrorAndStacktrace(this.error, this.stackTrace) - changed:
ctor GroupByStreamTransformer(this.grouper) → ctor GroupByStreamTransformer(S grouper(T event)) - changed:
ctor Notification.onError(dynamic e, StackTrace s) → ctor Notification.onError(dynamic error, StackTrace stackTrace) - changed:
ctor SampleStreamTransformer(Stream<dynamic> sampleStream, {bool sampleOnValueOnly = …}) → ctor SampleStreamTransformer(Stream window(T event)) - changed:
ctor ScanStreamTransformer(this.accumulator, [this.seed]) → ctor ScanStreamTransformer(S accumulator(S accumulated, T value, int index), [S seed]) - changed:
ctor SwitchLatestStream(this.streams) → ctor SwitchLatestStream(Stream<Stream<T>> streams) - changed:
ctor ThrottleStreamTransformer(Duration duration) → ctor ThrottleStreamTransformer(Stream window(T event), {bool trailing = …}) - changed:
ctor TimerStream(this.value, this.duration) → ctor TimerStream(T value, Duration duration) - changed:
ctor WindowStreamTransformer(this.sampler, {this.exhaustBufferOnDone = …}) → ctor WindowStreamTransformer(Stream window(T event)) - changed:
ctor WithLatestFromStreamTransformer(Stream<S> latestFromStream, R fn(T t, S s)) → ctor WithLatestFromStreamTransformer( Iterable<Stream<S>> latestFromStreams, R fn(T t, List<S> values)) - changed:
method Observable.buffer(SamplerBuilder<T, List<T>> sampler): Observable<List<T>> → method Observable.buffer(Stream window): Observable<List<T>> - changed:
method Observable.debounce(Duration duration): Observable<T> → method Observable.debounce(Stream window(T event)): Observable<T> - changed:
method Observable.pairwise(): Observable<List<T>> → method Observable.pairwise(): Observable<Iterable<T>> - changed:
method Observable.throttle(Duration duration): Observable<T> → method Observable.throttle(Stream window(T event), {bool trailing = …}): Observable<T> - changed:
method Observable.window(SamplerBuilder<T, Stream<T>> sampler): Observable<Stream<T>> → method Observable.window(Stream window): Observable<Stream<T>> - changed:
method TimerStream.listen(void onData(T event), {Function onError, void onDone(), bool cancelOnError}): StreamSubscription<T> → method TimerStream.listen(void Function(T event) onData, {Function onError, void Function() onDone, bool cancelOnError}): StreamSubscription<T> - added:
class BufferCountStreamTransformer<T> extends BackpressureStreamTransformer<T, List<T>> - added:
class BufferTestStreamTransformer<T> extends BackpressureStreamTransformer<T, List<T>> - added:
class ForkJoinStream<T, R> extends StreamView<R> - added:
class PairwiseStreamTransformer<T> extends BackpressureStreamTransformer<T, Iterable<T>> - added:
class SequenceEqualStream<S, T> extends Stream<bool> - added:
class WhereTypeStreamTransformer<S, T> extends StreamTransformerBase<S, T> - added:
class WindowCountStreamTransformer<T> extends BackpressureStreamTransformer<T, Stream<T>> - added:
class WindowTestStreamTransformer<T> extends BackpressureStreamTransformer<T, Stream<T>> - added:
ctor BufferCountStreamTransformer(int count, [int startBufferEvery = …]) - added:
ctor BufferTestStreamTransformer(bool test(T value)) - added:
ctor ForkJoinStream( Iterable<Stream<T>> streams, R combiner(List<T> values), ) - added:
ctor PairwiseStreamTransformer() - added:
ctor RetryError.onReviveFailed(List<ErrorAndStacktrace> errors) - added:
ctor RetryError.withCount(int count, List<ErrorAndStacktrace> errors) - added:
ctor SequenceEqualStream(Stream<S> stream, Stream<T> other, {bool equals(S s, T t)}) - added:
ctor WhereTypeStreamTransformer() - added:
ctor WindowCountStreamTransformer(int count, [int startBufferEvery = …]) - added:
ctor WindowTestStreamTransformer(bool test(T value)) - added:
field ErrorAndStacktrace.stackTrace: final StackTrace - added:
method DeferStream.Function(): Stream<T> - added:
method Observable.debounceTime(Duration duration): Observable<T> - added:
method Observable.sampleTime(Duration duration): Observable<T> - added:
method Observable.throttleTime(Duration duration, {bool trailing = …}): Observable<T> - added:
method Observable.whereType<S>(): Observable<S> - added:
method Observable.withLatestFrom2<A, B, R>( Stream<A> latestFromStream1, Stream<B> latestFromStream2, R fn(T t, A a, B b), ): Observable<R> - added:
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> - added:
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> - added:
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> - added:
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> - added:
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> - added:
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> - added:
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> - added:
method Observable.withLatestFromList( Iterable<Stream<T>> latestFromStreams): Observable<List<T>> - added:
method RetryStream.Function(): Stream<T> - added:
method RetryWhenStream.Function(): Stream<T> - added:
method SequenceEqualStream.listen(void onData(bool event), {Function onError, void onDone(), bool cancelOnError}): StreamSubscription<bool> - added:
method WhereTypeStreamTransformer.bind(Stream<S> stream): Stream<T> - added:
static method BehaviorSubject.Function(): Stream<T> - added:
static method ForkJoinStream.combine2<A, B, R>( Stream<A> streamOne, Stream<B> streamTwo, R combiner(A a, B b), ): ForkJoinStream<dynamic, R> - added:
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> - added:
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> - added:
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> - added:
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> - added:
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> - added:
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> - added:
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> - added:
static method ForkJoinStream.list<T>( Iterable<Stream<T>> streams, ): ForkJoinStream<T, List<T>> - added:
static method Observable.forkJoin2<A, B, T>( Stream<A> streamA, Stream<B> streamB, T combiner(A a, B b)): Observable<T> - added:
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> - added:
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> - added:
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> - added:
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> - added:
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> - added:
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> - added:
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> - added:
static method Observable.forkJoin<T, R>( Iterable<Stream<T>> streams, R combiner(List<T> values)): Observable<R> - added:
static method Observable.forkJoinList<T>(Iterable<Stream<T>> streams): Observable<List<T>> - added:
static method Observable.sequenceEqual<A, B>(Stream<A> stream, Stream<B> other, {bool equals(A a, B b)}): Observable<bool> - added:
static method WithLatestFromStreamTransformer.with1<T, S, R>( Stream<S> latestFromStream, R fn(T t, S s), ): WithLatestFromStreamTransformer<T, S, R> - added:
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> - added:
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> - added:
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> - added:
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> - added:
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> - added:
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> - added:
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… - added:
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… - added:
static method WithLatestFromStreamTransformer.withList<T>( Iterable<Stream<T>> latestFromStreams, ): WithLatestFromStreamTransformer<T, T, List<T>> - added:
typedef RetryWhenStreamFactory = Stream<void> Function( dynamic error, StackTrace stack)
- removed:
function Function( Stream<T> stream, OnDataTransform<T, S>, OnDataTransform<S, S>): Stream<S> - removed:
function Function( Stream<T> stream, OnDataTransform<T, S>, OnDataTransform<S, S>, ): Stream<S> - removed:
typedef Stream<S> SamplerBuilder<T, S>(Stream<T> stream, OnDataTransform<T, S> bufferHandler, OnDataTransform<S, S> scheduleHandler) - removed:
typedef void OnDataTransform<T, S>(T event, EventSink<S> sink, [int skip])
- removed:
class AmbStream<T> extends Stream<T> - removed:
ctor AmbStream(Iterable<Stream<T>> streams) - removed:
ctor RetryError(this.message, this.errors) - removed:
field AmbStream.controller: final StreamController<T> - removed:
field ConcatEagerStream.controller: final StreamController<T> - removed:
field ConcatStream.controller: final StreamController<T> - removed:
field ErrorAndStacktrace.stacktrace: final StackTrace - removed:
field ErrorStream.controller: StreamController<T> - removed:
field MergeStream.controller: final StreamController<T> - removed:
field NeverStream.controller: StreamController<T> - removed:
field RaceStream.controller: final StreamController<T> - removed:
field RangeStream.stream: final Stream<int> - removed:
field RepeatStream.controller: StreamController<T> - removed:
field RepeatStream.repeatStep: int - removed:
field RepeatStream.subscription: StreamSubscription<T> - removed:
field RetryStream.controller: StreamController<T> - removed:
field RetryStream.retryStep: int - removed:
field RetryStream.streamFactory: final StreamFactory<T> - removed:
field RetryStream.subscription: StreamSubscription<T> - removed:
field RetryWhenStream.controller: StreamController<T> - removed:
field RetryWhenStream.streamFactory: final StreamFactory<T> - removed:
field RetryWhenStream.subscription: StreamSubscription<T> - removed:
field SwitchLatestStream.streams: final Stream<Stream<T>> - removed:
field TimerStream.controller: final StreamController<T> - removed:
field TimerStream.duration: final Duration - removed:
field TimerStream.value: final T - removed:
method AmbStream.listen(void onData(T event), {Function onError, void onDone(), bool cancelOnError}): StreamSubscription<T> - removed:
method RepeatStream.maybeRepeatNext(): void - removed:
method RepeatStream.repeatNext(): void - removed:
method RetryStream.retry(): void - removed:
method RetryWhenStream.retry(): void - removed:
static method RangeStream.buildStream(int startInclusive, int endInclusive): Stream<int> - removed:
typedef Stream<T> StreamFactory<T>() - removed:
typedef Stream<void> RetryWhenStreamFactory(dynamic error, StackTrace stack) - changed:
ctor DeferStream(this._streamFactory, {bool reusable = …}) → ctor DeferStream(Stream<T> streamFactory(), {bool reusable = …}) - changed:
ctor ErrorAndStacktrace(this.error, this.stacktrace) → ctor ErrorAndStacktrace(this.error, this.stackTrace) - changed:
ctor SwitchLatestStream(this.streams) → ctor SwitchLatestStream(Stream<Stream<T>> streams) - changed:
ctor TimerStream(this.value, this.duration) → ctor TimerStream(T value, Duration duration) - changed:
method TimerStream.listen(void onData(T event), {Function onError, void onDone(), bool cancelOnError}): StreamSubscription<T> → method TimerStream.listen(void Function(T event) onData, {Function onError, void Function() onDone, bool cancelOnError}): StreamSubscription<T> - added:
class ForkJoinStream<T, R> extends StreamView<R> - added:
class SequenceEqualStream<S, T> extends Stream<bool> - added:
ctor ForkJoinStream( Iterable<Stream<T>> streams, R combiner(List<T> values), ) - added:
ctor RetryError.onReviveFailed(List<ErrorAndStacktrace> errors) - added:
ctor RetryError.withCount(int count, List<ErrorAndStacktrace> errors) - added:
ctor SequenceEqualStream(Stream<S> stream, Stream<T> other, {bool equals(S s, T t)}) - added:
field ErrorAndStacktrace.stackTrace: final StackTrace - added:
method DeferStream.Function(): Stream<T> - added:
method RetryStream.Function(): Stream<T> - added:
method RetryWhenStream.Function(): Stream<T> - added:
method SequenceEqualStream.listen(void onData(bool event), {Function onError, void onDone(), bool cancelOnError}): StreamSubscription<bool> - added:
static method ForkJoinStream.combine2<A, B, R>( Stream<A> streamOne, Stream<B> streamTwo, R combiner(A a, B b), ): ForkJoinStream<dynamic, R> - added:
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> - added:
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> - added:
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> - added:
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> - added:
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> - added:
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> - added:
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> - added:
static method ForkJoinStream.list<T>( Iterable<Stream<T>> streams, ): ForkJoinStream<T, List<T>> - added:
typedef RetryWhenStreamFactory = Stream<void> Function( dynamic error, StackTrace stack)
- removed:
field Subject.controller: final StreamController<T> - added:
static method BehaviorSubject.Function(): Stream<T>
- removed:
class FlatMapLatestStreamTransformer<T, S> extends StreamTransformerBase<T, S> - removed:
class OnErrorResumeNextStreamTransformer<T> extends StreamTransformerBase<T, T> - removed:
ctor FlatMapLatestStreamTransformer(Stream<S> mapper(T value)) - removed:
ctor OnErrorResumeNextStreamTransformer(Stream<T> recoveryStream) - removed:
field BufferStreamTransformer.exhaustBufferOnDone: final bool - removed:
field BufferStreamTransformer.sampler: final SamplerBuilder<T, List<T>> - removed:
field DebounceStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field DefaultIfEmptyStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field DelayStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field DematerializeStreamTransformer.transformer: final StreamTransformer<Notification<T>, T> - removed:
field DistinctUniqueStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field DoStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field ExhaustMapStreamTransformer.transformer: final StreamTransformer<T, S> - removed:
field FlatMapLatestStreamTransformer.transformer: final StreamTransformer<T, S> - removed:
field FlatMapStreamTransformer.transformer: final StreamTransformer<T, S> - removed:
field IgnoreElementsStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field IntervalStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field MapToStreamTransformer.transformer: final StreamTransformer<S, T> - removed:
field MaterializeStreamTransformer.transformer: final StreamTransformer<T, Notification<T>> - removed:
field OfTypeStreamTransformer.transformer: final StreamTransformer<T, S> - removed:
field OnErrorResumeNextStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field OnErrorResumeStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field SampleStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field ScanStreamTransformer.accumulator: final _ScanStreamTransformerAccumulator<T, S> - removed:
field ScanStreamTransformer.seed: final S - removed:
field SkipUntilStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field StartWithManyStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field StartWithStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field SwitchIfEmptyStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field SwitchMapStreamTransformer.transformer: final StreamTransformer<T, S> - removed:
field TakeUntilStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field ThrottleStreamTransformer.transformer: final StreamTransformer<T, T> - removed:
field TimeIntervalStreamTransformer.transformer: final StreamTransformer<T, TimeInterval<T>> - removed:
field TimestampStreamTransformer.transformer: final StreamTransformer<T, Timestamped<T>> - removed:
field WindowStreamTransformer.exhaustBufferOnDone: final bool - removed:
field WindowStreamTransformer.sampler: final SamplerBuilder<T, Stream<T>> - removed:
field WithLatestFromStreamTransformer.transformer: final StreamTransformer<T, R> - removed:
method BufferStreamTransformer.bind(Stream<T> stream): Stream<List<T>> - removed:
method DebounceStreamTransformer.bind(Stream<T> stream): Stream<T> - removed:
method FlatMapLatestStreamTransformer.bind(Stream<T> stream): Stream<S> - removed:
method GroupByStreamTransformer.Function(T): S - removed:
method OnErrorResumeNextStreamTransformer.bind(Stream<T> stream): Stream<T> - removed:
method SampleStreamTransformer.bind(Stream<T> stream): Stream<T> - removed:
method ThrottleStreamTransformer.bind(Stream<T> stream): Stream<T> - removed:
method WindowStreamTransformer.bind(Stream<T> stream): Stream<Stream<T>> - removed:
static method BufferStreamTransformer.assertSampler<T>(SamplerBuilder<T, List<T>> scheduler): void - removed:
static method WindowStreamTransformer.assertSampler<T>(SamplerBuilder<T, Stream<T>> scheduler): void - removed:
typedef Future<dynamic> FutureFunc() - removed:
typedef void VoidFunc() - changed:
class BufferStreamTransformer<T> extends StreamTransformerBase<T, List<T>> → class BufferStreamTransformer<T> extends BackpressureStreamTransformer<T, List<T>> - changed:
class DebounceStreamTransformer<T> extends StreamTransformerBase<T, T> → class DebounceStreamTransformer<T> extends BackpressureStreamTransformer<T, T> - changed:
class SampleStreamTransformer<T> extends StreamTransformerBase<T, T> → class SampleStreamTransformer<T> extends BackpressureStreamTransformer<T, T> - changed:
class ThrottleStreamTransformer<T> extends StreamTransformerBase<T, T> → class ThrottleStreamTransformer<T> extends BackpressureStreamTransformer<T, T> - changed:
class WindowStreamTransformer<T> extends StreamTransformerBase<T, Stream<T>> → class WindowStreamTransformer<T> extends BackpressureStreamTransformer<T, Stream<T>> - changed:
ctor BufferStreamTransformer(this.sampler, {this.exhaustBufferOnDone = …}) → ctor BufferStreamTransformer(Stream window(T event)) - changed:
ctor DebounceStreamTransformer(Duration duration) → ctor DebounceStreamTransformer(Stream window(T event)) - changed:
ctor GroupByStreamTransformer(this.grouper) → ctor GroupByStreamTransformer(S grouper(T event)) - changed:
ctor Notification.onError(dynamic e, StackTrace s) → ctor Notification.onError(dynamic error, StackTrace stackTrace) - changed:
ctor SampleStreamTransformer(Stream<dynamic> sampleStream, {bool sampleOnValueOnly = …}) → ctor SampleStreamTransformer(Stream window(T event)) - changed:
ctor ScanStreamTransformer(this.accumulator, [this.seed]) → ctor ScanStreamTransformer(S accumulator(S accumulated, T value, int index), [S seed]) - changed:
ctor ThrottleStreamTransformer(Duration duration) → ctor ThrottleStreamTransformer(Stream window(T event), {bool trailing = …}) - changed:
ctor WindowStreamTransformer(this.sampler, {this.exhaustBufferOnDone = …}) → ctor WindowStreamTransformer(Stream window(T event)) - changed:
ctor WithLatestFromStreamTransformer(Stream<S> latestFromStream, R fn(T t, S s)) → ctor WithLatestFromStreamTransformer( Iterable<Stream<S>> latestFromStreams, R fn(T t, List<S> values)) - added:
class BufferCountStreamTransformer<T> extends BackpressureStreamTransformer<T, List<T>> - added:
class BufferTestStreamTransformer<T> extends BackpressureStreamTransformer<T, List<T>> - added:
class PairwiseStreamTransformer<T> extends BackpressureStreamTransformer<T, Iterable<T>> - added:
class WhereTypeStreamTransformer<S, T> extends StreamTransformerBase<S, T> - added:
class WindowCountStreamTransformer<T> extends BackpressureStreamTransformer<T, Stream<T>> - added:
class WindowTestStreamTransformer<T> extends BackpressureStreamTransformer<T, Stream<T>> - added:
ctor BufferCountStreamTransformer(int count, [int startBufferEvery = …]) - added:
ctor BufferTestStreamTransformer(bool test(T value)) - added:
ctor PairwiseStreamTransformer() - added:
ctor WhereTypeStreamTransformer() - added:
ctor WindowCountStreamTransformer(int count, [int startBufferEvery = …]) - added:
ctor WindowTestStreamTransformer(bool test(T value)) - added:
method WhereTypeStreamTransformer.bind(Stream<S> stream): Stream<T> - added:
static method WithLatestFromStreamTransformer.with1<T, S, R>( Stream<S> latestFromStream, R fn(T t, S s), ): WithLatestFromStreamTransformer<T, S, R> - added:
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> - added:
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> - added:
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> - added:
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> - added:
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> - added:
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> - added:
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… - added:
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… - added:
static method WithLatestFromStreamTransformer.withList<T>( Iterable<Stream<T>> latestFromStreams, ): WithLatestFromStreamTransformer<T, T, List<T>>