• 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).