Update dependency rxdart to ^0.27.0

[renovate]

This PR contains the following updates:

Package	Type	Update	Change
rxdart	dependencies	minor	^0.26.0-nullsafety.0 -> ^0.27.0

---

Release Notes

ReactiveX/rxdart

v0.27.7

Compare Source

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.

v0.27.6

Compare Source

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

v0.27.5

Compare Source

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

v0.27.4

Compare Source

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

v0.27.3

Compare Source

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.

v0.27.2

Compare Source

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.

v0.27.1

Compare Source

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

v0.27.0

Compare Source

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

---

Configuration

📅 Schedule: Branch creation - At any time (no schedule defined), Automerge - At any time (no schedule defined).

🚦 Automerge: Disabled by config. Please merge this manually once you are satisfied.

♻ Rebasing: Whenever PR becomes conflicted, or you tick the rebase/retry checkbox.

🔕 Ignore: Close this PR and you won't be reminded about this update again.

---

• If you want to rebase/retry this PR, check this box

---

This PR has been generated by Mend Renovate. View repository job log here.

[renovate]

Edited/Blocked Notification

Renovate will not automatically rebase this PR, because it does not recognize the last commit author and assumes somebody else may have edited the PR.

You can manually request rebase by checking the rebase/retry box above.

⚠️ Warning: custom changes will be lost.