rxdart

New

• ValueStream:

  • Add lastEventOrNull getter to ValueStream,
    which returns the last emitted event (either data/value or error event), or null.
  • Add isLastEventValue, isLastEventError and errorAndStackTraceOrNull
    extension getters to ValueStream, to check the kind of the last emitted event is data/value or error.
  • Update documentation.

• ReplayStream:

  • Add errorAndStackTraces to ReplayStream, which returns a list of emitted ErrorAndStackTraces.

• Rename Notification and Kind to better reflect their purpose,
  and to avoid confusion with Flutter's Notification class.

  • Rename Notification to StreamNotification
    • Notification.onData to StreamNotification.data.
    • Notification.onDone to StreamNotification.done.
    • Notification.onError to StreamNotification.error.
  • Rename Kind to NotificationKind
    • Kind.onData to NotificationKind.data.
    • Kind.onError to NotificationKind.error.
    • Kind.onDone to NotificationKind.done.
  • Introduce DataNotification, ErrorNotification and DoneNotification as the subclasses of StreamNotification.
  • Convert isOnData, isOnError, isOnDone, requireData to extension getters on StreamNotification,
    they are now named isData, isError, isDone and requireDataValue.
  • Add extensions on StreamNotification: dataValueOrNull, requireErrorAndStackTrace, errorAndStackTraceOrNull getters and when method.

Changed

• Accept Dart SDK versions above 3.0.

• switchMap: when cancelling the previous inner subscription,
  switchMap will pause the outer subscription and and wait for the inner subscription to be completely canceled.
  It will then resume the outer subscription, and listen to the next inner Stream.
  Any errors from canceling the previous inner subscription will now be forwarded to the resulting Stream.

• Breaking: Rename ForkJoinStream.combine2..combine9 to ForkJoinStream.join2..join9.

• Breaking: Rx.using/UsingStream

  • Convert all required positional parameters to required named parameters.
  • The disposer is now called after the future returned from StreamSubscription.cancel completes.

Documentation

• Update and fix documentation.
• Fix README example (thanks to @wurikiji).
• Update Flutter example (thanks to @hoangchungk53qx1).
• Replace deprecated "dart pub run" with "dart run" (thanks to @tatsuyafujisaki).

New

• ValueStream:

  • Add lastEventOrNull getter to ValueStream, which returns the last emitted event (either data/value or error event), or null.
  • Add isLastEventValue, isLastEventError and errorAndStackTraceOrNull extension getters to ValueStream, to check the kind of the last emitted event is data/value or error.
  • Update documentation.

• ReplayStream:

  • Add errorAndStackTraces to ReplayStream, which returns a list of emitted ErrorAndStackTraces.

• Rename Notification and Kind to better reflect their purpose, and to avoid confusion with Flutter's Notification class.

  • Rename Notification to StreamNotification
    • Notification.onData to StreamNotification.data.
    • Notification.onDone to StreamNotification.done.
    • Notification.onError to StreamNotification.error.
  • Rename Kind to NotificationKind
    • Kind.onData to NotificationKind.data.
    • Kind.onError to NotificationKind.error.
    • Kind.onDone to NotificationKind.done.
  • Introduce DataNotification, ErrorNotification and DoneNotification as the subclasses of StreamNotification.
  • Convert isOnData, isOnError, isOnDone, requireData to extension getters on StreamNotification, they are now named isData, isError, isDone and requireDataValue.
  • Add extensions on StreamNotification: dataValueOrNull, requireErrorAndStackTrace, errorAndStackTraceOrNull getters and when method.

Changed

• Accept Dart SDK versions above 3.0.

• switchMap: when cancelling the previous inner subscription, switchMap will pause the outer subscription and and wait for the inner subscription to be completely canceled. It will then resume the outer subscription, and listen to the next inner Stream. Any errors from canceling the previous inner subscription will now be forwarded to the resulting Stream.

• Breaking: Rename ForkJoinStream.combine2..combine9 to ForkJoinStream.join2..join9.

• Breaking: Rx.using/UsingStream

  • Convert all required positional parameters to required named parameters.
  • The disposer is now called after the future returned from StreamSubscription.cancel completes.

Documentation

• Update and fix documentation.
• Fix README example (thanks to @wurikiji).
• Update Flutter example (thanks to @hoangchungk53qx1).
• Replace deprecated "dart pub run" with "dart run" (thanks to @tatsuyafujisaki).

Feedback on this change appreciated as this is a dev release before 0.28.0 stable!

Changed

• Breaking: Rename ForkJoinStream.combine2..combine9 to ForkJoinStream.join2..join9.
• Breaking: Rx.using/UsingStream
  • Convert all required positional parameters to required named parameters.
  • The disposer is now called after the future returned from StreamSubscription.cancel completes.

Feedback on this change appreciated as this is a dev release before 0.28.0 stable!

Changed

• Breaking: Rename ForkJoinStream.combine2..combine9 to ForkJoinStream.join2..join9.
• Breaking: Rx.using/UsingStream
  • Convert all required positional parameters to required named parameters.
  • The disposer is now called after the future returned from StreamSubscription.cancel completes.

https://pub.dev/packages/rxdart/versions/0.28.0-dev.1

Feedback on this change appreciated as this is a dev release before 0.28.0 stable!

Changed

• switchMap: when cancelling the previous inner subscription,
  switchMap will pause the outer subscription and and wait for the inner subscription to be completely canceled.
  It will then resume the outer subscription, and listen to the next inner Stream.
  Any errors from canceling the previous inner subscription will now be forwarded to the resulting Stream.

Documentation

• Replace deprecated "dart pub run" with "dart run" (thanks to @tatsuyafujisaki).

What's Changed

• Replace deprecated "dart pub run" with "dart run" by @tatsuyafujisaki in #739
• switchMap: pause the outer subscription when cancelling the inner subscription, then resuming by @hoc081098 in #737
• Fix LICENSE by @hoc081098 in #741
• Update README.md [skip ci] by @hoc081098 in #742
• chore(publish): prepare for v0.28.0-dev.1 by @hoc081098 in #745

New Contributors

• @tatsuyafujisaki made their first contribution in #739

Full Changelog: 0.28.0-dev.0...0.28.0-dev.1

Feedback on this change appreciated as this is a dev release before 0.28.0 stable!

Changed

• switchMap: when cancelling the previous inner subscription, switchMap will pause the outer subscription and and wait for the inner subscription to be completely canceled. It will then resume the outer subscription, and listen to the next inner Stream. Any errors from canceling the previous inner subscription will now be forwarded to the resulting Stream.

Documentation

• Replace deprecated "dart pub run" with "dart run" (thanks to @tatsuyafujisaki).

https://pub.dev/packages/rxdart/versions/0.28.0-dev.0

Feedback on this change appreciated as this is a dev release before 0.28.0 stable!

New

• ValueStream:

  • Add lastEventOrNull getter to ValueStream,
    which returns the last emitted event (either data/value or error event), or null.
  • Add isLastEventValue, isLastEventError and errorAndStackTraceOrNull
    extension getters to ValueStream, to check the kind of the last emitted event is data/value or error.
  • Update documentation.

• ReplayStream:

  • Add errorAndStackTraces to ReplayStream, which returns a list of emitted ErrorAndStackTraces.

• Rename Notification and Kind to better reflect their purpose,
  and to avoid confusion with Flutter's Notification class.

  • Rename Notification to StreamNotification
    • Notification.onData to StreamNotification.data.
    • Notification.onDone to StreamNotification.done.
    • Notification.onError to StreamNotification.error.
  • Rename Kind to NotificationKind
    • Kind.onData to NotificationKind.data.
    • Kind.onError to NotificationKind.error.
    • Kind.onDone to NotificationKind.done.
  • Introduce DataNotification, ErrorNotification and DoneNotification as the subclasses of StreamNotification.
  • Convert isOnData, isOnError, isOnDone, requireData to extension getters on StreamNotification,
    they are now named isData, isError, isDone and requireDataValue.
  • Add extensions on StreamNotification: dataValueOrNull, requireErrorAndStackTrace, errorAndStackTraceOrNull getters and when method.

Changed

• Accept Dart SDK versions above 3.0.

Documentation

• Update and fix documentation.
• Fix README example (thanks to @wurikiji).
• Update Flutter example (thanks to @hoangchungk53qx1).

What's Changed

• docs(using): fix typo by @hoc081098 in #704
• improve Notification.toString(), add tests for Notifications by @hoc081098 in #703
• fix example on README by @wurikiji in #712
• Create .github/dependabot.yml by @hoc081098 in #714
• update example github_search by @hoangchungk53qx1 in #717
• Fix lints and accept Dart SDK versions above 3.0 by @hoc081098 in #721
• feat(ValueStream): add lastEventOrNull, isLastEventValue, isLastEventError, errorAndStackTraceOrNull by @hoc081098 in #729
• refactor(utils): rename Notification to StreamNotification, Kind to NotificationKind by @hoc081098 in #731
• docs: update docs by @hoc081098 in #733
• chore(publish): prepare for v0.28.0-dev.0 by @hoc081098 in #734

New Contributors

• @wurikiji made their first contribution in #712
• @hoangchungk53qx1 made their first contribution in #717

Full Changelog: 0.27.7...0.28.0-dev.0

Feedback on this change appreciated as this is a dev release before 0.28.0 stable!

New

• ValueStream:

  • Add lastEventOrNull getter to ValueStream, which returns the last emitted event (either data/value or error event), or null.
  • Add isLastEventValue, isLastEventError and errorAndStackTraceOrNull extension getters to ValueStream, to check the kind of the last emitted event is data/value or error.
  • Update documentation.

• ReplayStream:

  • Add errorAndStackTraces to ReplayStream, which returns a list of emitted ErrorAndStackTraces.

• Rename Notification and Kind to better reflect their purpose, and to avoid confusion with Flutter's Notification class.

  • Rename Notification to StreamNotification
    • Notification.onData to StreamNotification.data.
    • Notification.onDone to StreamNotification.done.
    • Notification.onError to StreamNotification.error.
  • Rename Kind to NotificationKind
    • Kind.onData to NotificationKind.data.
    • Kind.onError to NotificationKind.error.
    • Kind.onDone to NotificationKind.done.
  • Introduce DataNotification, ErrorNotification and DoneNotification as the subclasses of StreamNotification.
  • Convert isOnData, isOnError, isOnDone, requireData to extension getters on StreamNotification, they are now named isData, isError, isDone and requireDataValue.
  • Add extensions on StreamNotification: dataValueOrNull, requireErrorAndStackTrace, errorAndStackTraceOrNull getters and when method.

Changed

• Accept Dart SDK versions above 3.0.

Documentation

• Update and fix documentation.
• Fix README example (thanks to @wurikiji).
• Update Flutter example (thanks to @hoangchungk53qx1).

https://pub.dev/packages/rxdart/versions/0.27.7

Fixed

• Subject

  • Only call onAdd and onError if the subject is not closed.
    This ensures BehaviorSubject and ReplaySubject do not update their values after they have been closed.

  • Subject.stream now returns a read-only Stream.
    Previously, Subject.stream was identical to the Subject, so we could add events to it, for example: (subject.stream as Sink<T>).add(event).
    This behavior is now disallowed, and will throw a TypeError if attempted. Use Subject.sink/Subject itself for adding events.

  • Change return type of ReplaySubject<T>.stream to ReplayStream<T>.

  • Internal refactoring of Subject.addStream.

What's Changed

• fix(subject): only call onAdd and onError if the subject is not closed by @hoc081098 in #698
• refactor(subject): Subject.stream now returns a read-only Stream by @hoc081098 in #699
• refactor(subject): addStream by @hoc081098 in #700
• chore(publish): prepare for v0.27.7 by @hoc081098 in #701

Full Changelog: 0.27.6...0.27.7

Fixed

• Subject

  • Only call onAdd and onError if the subject is not closed. This ensures BehaviorSubject and ReplaySubject do not update their values after they have been closed.

  • Subject.stream now returns a read-only Stream. Previously, Subject.stream was identical to the Subject, so we could add events to it, for example: (subject.stream as Sink<T>).add(event). This behavior is now disallowed, and will throw a TypeError if attempted. Use Subject.sink/Subject itself for adding events.

  • Change return type of ReplaySubject<T>.stream to ReplayStream<T>.

  • Internal refactoring of Subject.addStream.

https://pub.dev/packages/rxdart/versions/0.27.6

• Rx.using/UsingStream: resourceFactory can now return a Future.
  This allows for asynchronous resource creation.

• Rx.range/RangeStream: ensure RangeStream is only listened to once.

What's Changed

• fix(range): make sure RangeStream can only be listened to once by @hoc081098 in #690
• fix(range): ensure RangeStream is only listened to once by @hoc081098 in #694
• refactor(Rx.using): resourceFactory can return a Future by @hoc081098 in #696
• chore(publish): prepare for v0.27.6 by @hoc081098 in #697

Full Changelog: 0.27.5...0.27.6

• Rx.using/UsingStream: resourceFactory can now return a Future. This allows for asynchronous resource creation.

• Rx.range/RangeStream: ensure RangeStream is only listened to once.

https://pub.dev/packages/rxdart/versions/0.27.5

Bug fixes

• Fix issue #683: Throws runtime type error when using extension
  methods on a Stream<R> but its type annotation is Stream<T>, R is a subtype of T
  (covariance issue with StreamTransformer).

  Stream<num> s1 = Stream<int>.fromIterable([1, 2, 3]);
  // throws "type 'SwitchMapStreamTransformer<num, num>' is not a subtype of type 'StreamTransformer<int, num>' of 'streamTransformer'"
  s1.switchMap((v) => Stream.value(v));
  
  Stream<int?> s2 = Stream<int>.fromIterable([1, 2, 3]);
  // throws "type 'SwitchMapStreamTransformer<int?, int?>' is not a subtype of type 'StreamTransformer<int, int?>' of 'streamTransformer'"
  s2.switchMap((v) => Stream.value(v));

  Extension methods were previously implemented via stream.transform(streamTransformer), now
  via streamTransformer.bind(stream) to avoid this issue.

• Fix concatEager: activeSubscription should be changed to next subscription.

Code refactoring

• Change return type of pairwise to Stream<List<T>>.

What's Changed

• Fix ConcatEagerStream bug by @Stitch-Taotao in #682
• Fix #683 by @hoc081098 in #684
• refactor(pairwise): change return type of pairwise to Stream<List> by @hoc081098 in #685
• Update CHANGELOG.md by @hoc081098 in #686
• prepare for v0.27.5 by @hoc081098 in #688

New Contributors

• @Stitch-Taotao made their first contribution in #682

Full Changelog: 0.27.4...0.27.5

Bug fixes

• Fix issue #683: Throws runtime type error when using extension methods on a Stream<R> but its type annotation is Stream<T>, R is a subtype of T (covariance issue with StreamTransformer).

  Stream<num> s1 = Stream<int>.fromIterable([1, 2, 3]);
  // throws "type 'SwitchMapStreamTransformer<num, num>' is not a subtype of type 'StreamTransformer<int, num>' of 'streamTransformer'"
  s1.switchMap((v) => Stream.value(v));
  
  Stream<int?> s2 = Stream<int>.fromIterable([1, 2, 3]);
  // throws "type 'SwitchMapStreamTransformer<int?, int?>' is not a subtype of type 'StreamTransformer<int, int?>' of 'streamTransformer'"
  s2.switchMap((v) => Stream.value(v));
  

  Extension methods were previously implemented via stream.transform(streamTransformer), now via streamTransformer.bind(stream) to avoid this issue.

• Fix concatEager: activeSubscription should be changed to next subscription.

Code refactoring

• Change return type of pairwise to Stream<List<T>>.

https://pub.dev/packages/rxdart/versions/0.27.4

Bug fixes

• withLatestFrom should iterate over Iterable<Stream>s only once when the stream is listened to.
• Fix analyzer warnings when using Dart 2.16.0.

Features

• Add mapNotNull/MapNotNullStreamTransformer.
• Add whereNotNull/WhereNotNullStreamTransformer.

Documentation

• Fix grammar errors in code examples (thanks to @fzyzcjy).
• Update RxMarbles URL for RaceStream (thanks to @Péter Ferenc Gyarmati).

What's Changed

• test(flatMap): fix flatMap tests by @hoc081098 in #658
• fix(withLatestFrom): should iterate over Iterable<Stream> once by @hoc081098 in #662
• fix: analyzer when using Dart 2.16.0 by @hoc081098 in #663
• Fix grammar errors in code examples by @fzyzcjy in #664
• docs: update rxmarbles URL for RaceStream by @peter-gy in #669
• Fix ci error pub: command not found by @beeth0ven in #673
• ci: remove deprecated packages flag by @beeth0ven in #674
• Create flutter-example.yml by @hoc081098 in #676
• Update flutter-example.yml by @hoc081098 in #677
• Add mapNotNull and whereNotNull by @hoc081098 in #548
• Prepare for v0.27.4 by @hoc081098 in #679

New Contributors

• @fzyzcjy made their first contribution in #664
• @peter-gy made their first contribution in #669
• @beeth0ven made their first contribution in #673

Full Changelog: 0.27.3...0.27.4

Bug fixes

• withLatestFrom should iterate over Iterable<Stream> only once when the stream is listened to.
• Fix analyzer warnings when using Dart 2.16.0.

Features

• Add mapNotNull/MapNotNullStreamTransformer.
• Add whereNotNull/WhereNotNullStreamTransformer.

Documentation

• Fix grammar errors in code examples (thanks to @fzyzcjy).
• Update RxMarbles URL for RaceStream (thanks to @Péter Ferenc Gyarmati).

https://pub.dev/packages/rxdart/versions/0.27.3

Bug fixes

• flatMap now creates inner Streams lazily.
• combineLatest, concat, concatEager, forkJoin, merge, race, zip iterate over Iterable<Stream>s only once
  when the stream is listened to.
• Disallow mixing autoConnect, connect and refCount together, only one of them should be used.

Features

• Introduce AbstractConnectableStream, base class for the ConnectableStream implementations.
• Improve CompositeSubscription (thanks to @BreX900)
  • CompositeSubscription's dispose, clear, and remove methods now return a completion future.
  • Fixed an issue where a stream not present in CompositeSubscription was canceled.
  • Added the ability not to cancel the stream when it is removed from CompositeSubscription.
  • CompositeSubscription implements StreamSubscription.
  • CompositeSubscription.add will throw a StateError instead of a String if this composite was disposed.

Documentation

• Fix Connectable examples.
• Update Web example to null safety.
• Fix Flutter example: SearchResultItem.fromJson type error (thanks to @WenYeh)

Code refactoring

• Simplify takeLast implementation.
• Migrate from pedantic to lints and flutter_lints.
• Refactor BehaviorSubject, ReplaySubject implementations by using "Sentinel object"s instead of ValueWrappers.

New Contributors

• @wayne900204 made their first contribution in #627
• @BreX900 made their first contribution in #633

Full Changelog: 0.27.2...0.27.3

Bug fixes

• flatMap now creates inner Streams lazily.
• combineLatest, concat, concatEager, forkJoin, merge, race, zip iterate over Iterable<Stream>s only once when the stream is listened to.
• Disallow mixing autoConnect, connect and refCount together, only one of them should be used.

Features

• Introduce AbstractConnectableStream, base class for the ConnectableStream implementations.
• Improve CompositeSubscription (thanks to @BreX900)
  • CompositeSubscription's dispose, clear, and remove methods now return a completion future.
  • Fixed an issue where a stream not present in CompositeSubscription was canceled.
  • Added the ability not to cancel the stream when it is removed from CompositeSubscription.
  • CompositeSubscription implements StreamSubscription.
  • CompositeSubscription.add will throw a StateError instead of a String if this composite was disposed.

Documentation

• Fix Connectable examples.
• Update Web example to null safety.
• Fix Flutter example: SearchResultItem.fromJson type error (thanks to @WenYeh)

Code refactoring

• Simplify takeLast implementation.
• Migrate from pedantic to lints and flutter_lints.
• Refactor BehaviorSubject, ReplaySubject implementations by using "Sentinel object"s instead of ValueWrappers.

Bug fixes

• onErrorReturnWith now does not drop the remaining data events after the first error.
• Disallow changing handlers of ConnectableStreamSubscription.

Features

• Add delayWhen operator.
• Add optional parameter maxConcurrent to flatMap.
• groupBy
  • Rename GroupByStream to GroupedStream.
  • Add optional parameter durationSelector, which used to determine how long each group should exist.
• ignoreElements
  • Remove @deprecated annotation (ignoreElements should not be marked as deprecated).
  • Change return type to Stream<Never>.

Documentation

• Update to PublishSubject's docs (thanks to @AlexanderJohr).

Code refactoring

• Refactoring Stream Transformers, using Stream.multi internally.

• Bugfix: ForkJoinStream throws Null check operator used on a null value when using nullable-type.
• Bugfix: delay operator
  • Pause and resume properly.
  • Cancel all timers after it has been cancelled.

• BREAKING: ValueStream
  • Remove ValueStreamExtensions.
  • ValueStream.valueWrapper becomes
    • value.
    • valueOrNull.
    • hasValue.
  • ValueStream.errorAndStackTrace becomes
    • error.
    • errorOrNull.
    • hasError.
    • stackTrace.
  • Add skipLast/SkipLastStreamTransformer (thanks @HannibalKcc).
  • Update scan: change seed to required param.
  • Add StackTrace param to recoveryFn when using OnErrorResumeStreamTransformer/onErrorResume/onErrorReturnWith.
  • Internal refactoring ConnectableStream.

• Stable, null-safe release.
  • Add takeLast (thanks @ThomasKliszowski).
  • Rework for retry/retryWhen:
    • Removed RetryError.
    • retry: emits all errors if retry fails.
    • retryWhen: emits original error, and error from factory if they are not identical.
    • streamFactory now accepts non-nullable StackTrace argument.
  • Update ValueStream.requireValue and ValueStream.requireError: throws actual error or a StateError, instead of throwing "Null check operator used on a null value" error.

• Breaking change: ValueStream
  • Add valueWrapper to ValueStream.
  • Change value, hasValue, error and hasError to extension getters.
  • Fixed some API example documentation (thanks @HannibalKcc).
  • throttle/throttleTime have been optimised for performance.
  • Updated Flutter example to work with the latest Flutter stable.

• Migrate this package to null safety.
  • Sdk constraints: >=2.12.0-0 <3.0.0 based on beta release guidelines.

• Sync behavior when using publishValueSeeded.
  • ValueStream, ReplayStream: exposes stackTrace along with the error:
    • Change ValueStream.error to ValueStream.errorAndStackTrace.
    • Change ReplayStream.errors to ReplayStream.errorAndStackTraces.
    • Merge Notification.error and Notification.stackTrace into Notification.errorAndStackTrace.
  • Bugfix: debounce/debounceTime unnecessarily kept too many elements in queue.

• Bugfix: switchMap doesn't close after the last inner Stream closes.
  • Docs: updated URL for "Single-Subscription vs. Broadcast Streams" doc (thanks Aman Gupta).
  • Add FromCallableStream/Rx.fromCallable: allows you to create a Stream from a callable function.
  • Override BehaviorSubject's built-in operators to correct replaying the latest value of BehaviorSubject.
  • Bugfix: Source StreamSubscription doesn't cancel when cancelling refCount, zip, merge, concat StreamSubscription.
  • Forward done event of upstream to ConnectableStream.

• Internal refactoring Stream Transformers.
  • Fixed RetryStream example documentation.
  • Error thrown from DeferStream factory will now be caught and converted to Stream.error.
  • doOnError now have strong type signature: Stream<T> doOnError(void Function(Object, StackTrace) onError).
  • Updated ForkJoinStream:
    • When any Stream emits an error, listening still continues unless cancelOnError: true on the downstream.
    • Pause and resume Streams properly.
  • Added UsingStream.
  • Updated TimerStream: Pause and resume Timer when pausing and resuming StreamSubscription.

• stream transformations on a ValueStream will also return a ValueStream, instead of a standard broadcast Stream
  • throttle can now be both leading and trailing
  • better handling of empty Lists when using operators that accept a List as input
  • error & hasError added to BehaviorSubject
  • various docs updates
  • note that this is a beta release, mainly because the behavior of transform has been adjusted (see first bullet) if all goes well, we'll release a proper 0.25.0 release soon

• Fix for BehaviorSubject, no longer emits null when using addStream and expecting an Error as first event (thanks yuvalr1)
  • min/max have been optimised for performance
  • Further refactors on our Transformers

• Fix throttle no longer outputting the current buffer onDone
  • Adds endWith and endWithMany
  • Fix when using pipe and an Error, Subjects would throw an Exception that couldn't be caught using onError
  • Updates links for docs (thanks @renefloor)
  • Fix links to correct marbles diagram for debounceTime (thanks @wheater)
  • Fix flakiness of withLatestFrom test Streams
  • Update to docs (@wheater)
  • Fix withLatestFrom not pause/resume/cancelling underlying Streams
  • Support sync behavior for Subjects
  • Add addTo extension for StreamSubscription, use it to easily add a subscription to a CompositeSubscription
  • Fix mergeWith and zipWith will return a broadcast Stream, if the source Stream is also broadcast
  • Fix concatWith will return a broadcast Stream, if the source Stream is also broadcast (thanks @jarekb123)
  • Adds pauseAll, resumeAll, ... to CompositeSubscription
  • Additionally, fixes some issues introduced with 0.24.0-dev.1

• Breaking: as of this release, we've refactored the way Stream transformers are set up. Previous releases had some incorrect behavior when using certain operators, for example:

  • startWith (startWithMany, startWithError) would incorrectly replay the starting event(s) when using a broadcast Stream at subscription time.

  • doOnX was not always producing the expected results:

    • doOnData did not output correct sequences on streams that were transformed multiple times in sequence.
    • doOnCancel now acts in the same manner onCancel works on regular subscriptions, i.e. it will now be called when all active subscriptions on a Stream are cancelled.
    • doOnListen will now call the first time the Stream is subscribed to, and will only call again after all subscribers have cancelled, before a new subscription starts.

    To properly fix this up, a new way of transforming Streams was introduced.
    Operators as of now use Stream.eventTransformed and we've refactored all operators to implement Sink instead.

  • Adds takeWileInclusive operator (thanks to @hoc081098)

  We encourage everyone to give the dev release(s) a spin and report back if anything breaks. If needed, a guide will be written to help migrate from the old behavior to the new behavior in certain common use cases.

  Keep in mind that we tend to stick as close as we can to how normal Dart Streams work!

• Fix API doc links in README

• Extension Methods replace Observable class!
  • Please upgrade existing code by using the rxdart_codemod package
  • Remove the Observable class. With extensions, you no longer need to wrap Streams in a [Stream]!
    • Convert all factories to static constructors to aid in discoverability of Stream classes
    • Move all factories to an Rx class.
    • Remove Observable.just, use Stream.value
    • Remove Observable.error, use Stream.error
    • Remove all tests that check base Stream methods
    • Subjects and *Observable classes extend Stream instead of base Observable
    • Rename *Observable to *Stream to reflect the fact they're just Streams.
      • ValueObservable -> ValueStream
      • ReplayObservable -> ReplayStream
      • ConnectableObservable -> ConnectableStream
      • ValueConnectableObservable -> ValueConnectableStream
      • ReplayConnectableObservable -> ReplayConnectableStream
  • All transformation methods removed from Observable class
    • Transformation methods are now Extensions of the Stream class
    • Any Stream can make use of the transformation methods provided by RxDart
    • Observable class remains in place with factory methods to create different types of Streams
    • Removed deprecated ofType method, use whereType instead
    • Deprecated concatMap, use standard Stream asyncExpand.
    • Removed AsObservableFuture, MinFuture, MaxFuture, and WrappedFuture
      • This removes asObservable method in chains
      • Use default asStream method from the base Future class instead.
      • min and max now implemented directly on the Stream class

• Fix missing exports:
  • ValueStream
  • ReplayStream
  • ConnectableStream
  • ValueConnectableStream
  • ReplayConnectableStream

• Remove the Observable class. With extensions, you no longer need to wrap Streams in a [Stream]!
  • Convert all factories to static constructors to aid in discoverability of Stream classes
  • Move all factories to an Rx class.
  • Remove Observable.just, use Stream.value
  • Remove Observable.error, use Stream.error
  • Remove all tests that check base Stream methods
  • Subjects and *Observable classes extend Stream instead of base Observable
  • Rename *Observable to *Stream to reflect the fact they're just Streams.
    • ValueObservable -> ValueStream
    • ReplayObservable -> ReplayStream
    • ConnectableObservable -> ConnectableStream
    • ValueConnectableObservable -> ValueConnectableStream
    • ReplayConnectableObservable -> ReplayConnectableStream

• Feedback on this change appreciated as this is a dev release before 0.23.0 stable!
  • All transformation methods removed from Observable class
    • Transformation methods are now Extensions of the Stream class
    • Any Stream can make use of the transformation methods provided by RxDart
  • Observable class remains in place with factory methods to create different types of Streams
  • Removed deprecated ofType method, use whereType instead
  • Deprecated concatMap, use standard Stream asyncExpand.
  • Removed AsObservableFuture, MinFuture, MaxFuture, and WrappedFuture
    • This removes asObservable method in chains
    • Use default asStream method from the base Future class instead.
    • min and max now implemented directly on the Stream class

• Bugfix: When listening multiple times to aBehaviorSubject that starts with an Error, it emits duplicate events.
  • Linter: public_member_api_docs is now used, we have added extra documentation where required.

• Bugfix: DeferStream created Stream too early
  • Bugfix: TimerStream created Timer too early

• Bugfix: switchMap controller no longer closes prematurely

• Bugfix: whereType failing in Flutter production builds only

• Bugfix: When using a seeded BehaviorSubject and adding an Error, upon listening, the BehaviorSubject emits null instead of the last Error.
  • Bugfix: calling cancel after a switchMap can cause a NoSuchMethodError.
  • Updated Flutter example to match the latest Flutter release
  • Observable.withLatestFrom is now expanded to accept 2 or more Streams thanks to Petrus Nguyễn Thái Học (@hoc081098)!
  • Deprecates ofType in favor of whereType, drop TypeToken.

Fixes following issues:

• Erroneous behavior with scan and BehaviorSubject.
• Bug where flatMap would cancel inner subscriptions in pause/resume.
• Updates to make the current "pedantic" analyzer happy.

This version includes refactoring for the backpressure operators:

• Breaking Change: debounce is now split into debounce and debounceTime.
• Breaking Change: sample is now split into sample and sampleTime.
• Breaking Change: throttle is now split into throttle and throttleTime.

• Breaking Change: BehaviorSubject now has a separate factory constructor seeded() This allows you to seed this Subject with a null value.
  • Breaking Change: BehaviorSubject will now emit an Error, if the last event was also an Error. Before, when an Error occurred before a listen, the subscriber would not be notified of that Error. To refactor, simply change all occurences of BehaviorSubject(seedValue: value) to BehaviorSubject.seeded(value)
  • Added the groupBy operator
  • Bugix: doOnCancel: will now await the cancel result, if it is a Future.
  • Removed: bufferWithCount, windowWithCount, tween Please use bufferCount and windowCount, tween is removed, because it never was an official Rx spec.
  • Updated Flutter example to work with the latest Flutter stable.

• Breaking Change: bufferCount had buggy behavior when using startBufferEvery (was skip previously) If you were relying on bufferCount with skip greater than 1 before, then you may have noticed erroneous behavior.
  • Breaking Change: repeat is no longer an operator which simply repeats the last emitted event n-times, instead this is now an Observable factory method which takes a StreamFactory and a count parameter. This will cause each repeat cycle to create a fresh Observable sequence.
  • mapTo is a new operator, which works just like map, but instead of taking a mapper Function, it takes a single value where each event is mapped to.
  • Bugfix: switchIfEmpty now correctly calls onDone
  • combineLatest and zip can now take any amount of Streams:
    • combineLatest2-9 & zip2-9 functionality unchanged, but now use a new path for construction.
    • adds combineLatest and zipLatest which allows you to pass through an Iterable<Stream<T>> and a combiner that takes a List<T> when any source emits a change.
    • adds combineLatestList / zipList which allows you to take in an Iterable<Stream<T>> and emit a Observable<List<T>> with the values. Just a convenience factory if all you want is the list!
    • Constructors are provided by the Stream implementation directly
  • Bugfix: Subjects that are transformed will now correctly return a new Observable where isBroadcast is true (was false before)
  • Remove deprecated operators which were replaced long ago: bufferWithCount, windowWithCount, amb, flatMapLatest

• Breaking Change: Subjects onCancel function now returns void instead of Future to properly comply with the StreamController signature.
  • Bugfix: FlatMap operator properly calls onDone for all cases
  • Connectable Observable: An observable that can be listened to multiple times, and does not begin emitting values until the connect method is called
  • ValueObservable: A new interface that allows you to get the latest value emitted by an Observable.
    • Implemented by BehaviorSubject
    • Convert normal observables into ValueObservables via publishValue or shareValue
  • ReplayObservable: A new interface that allows you to get the values emitted by an Observable.
    • Implemented by ReplaySubject
    • Convert normal observables into ReplayObservables via publishReplay or shareReplay

• Add retryWhen operator. Thanks to Razvan Lung (@long1eu)! This can be used for custom retry logic.

• Breaking Change: remove retype method, deprecated as part of Dart 2.
• Add flatMapIterable

• Breaking Change: stream property on Observable is now private.
  • Avoids API confusion
  • Simplifies Subject implementation
  • Require folks who are overriding the stream property to use a super constructor instead
• Adds proper onPause and onResume handling for amb/race, combineLatest, concat, concat_eager, merge and zip
• Add switchLatest operator
• Add errors and stacktraces to RetryError class
• Add onErrorResume and onErrorRetryWith operators. These allow folks to return a specific stream or value depending on the error that occurred.

• Fix new buffer and window implementation for Flutter + Dart 2
• Subject now implements the Observable interface

• Rework for buffer and window, allow to schedule using a sampler
• added buffer
• added bufferFuture
• added bufferTest
• added bufferTime
• added bufferWhen
• added window
• added windowFuture
• added windowTest
• added windowTime
• added windowWhen
• added onCount sampler for buffer and window
• added onFuture sampler for buffer and window
• added onTest sampler for buffer and window
• added onTime sampler for buffer and window
• added onStream sampler for buffer and window

• Renames amb to race
• Renames flatMapLatest to switchMap
• Renames bufferWithCount to bufferCount
• Renames windowWithCount to windowCount

• Adds bufferTime transformer.
• Adds windowTime transformer.

• Adds delay transformer.

• Fix added events to sink are not processed correctly by Subjects.

• Fix dematerialize method for Dart 2.

• breaks backwards compatibility, this release only works with Dart SDK >=2.0.0.
• Removed old cast in favour of the now native Stream cast method.
• Override retype to return an Observable.

• Update Changelog

• Add value to BehaviorSubject. Allows you to get the latest value emitted by the subject if it exists.
• Add values to ReplayrSubject. Allows you to get the values stored by the subject if any exists.

• Add exhaustMap map to inner observable, ignore other values until that observable completes.
• Improved code to be dartdevc compatible.
• Add upper SDK version limit in pubspec

• Change debounce to emit the last item of the source stream as soon as the source stream completes.
• Ensure debounce does not keep open any addition async timers after it has been cancelled.

• Add PublishSubject (thanks to @pauldemarco)
• Fix bug with doOnX operators where callbacks were fired too often

• Change DoStreamTransformer to return a Future on cancel for api compatibility.

• Fix error with FlatMapLatest where it was not properly cancelled in some scenarios
• Remove additional async methods on Stream handlers unless they're shown to solve a problem

• Remove call operator / StreamTransformer entirely
• Important bug fix: Errors thrown within any Stream or Operator will now be properly sent to the StreamSubscription.
• Improve overall handling of errors throughout the library to ensure they're handled correctly

• Added doOn* operators in place of call.
• Added DoStreamTransformer as a replacement for CallStreamTransformer
• Deprecated call and CallStreamTransformer. Please use the appropriate doOnX operator / transformer.
• Added distinctUnique. Emits items if they've never been emitted before. Same as to Rx#distinct.

• !!!Breaking Api Change!!!
  • Observable.groupBy has been removed in order to be compatible with the next version of the Stream class in Dart 1.24.0, which includes this method