Upgrading rxdart 0.23 to 0.24
Breaking0.23.1 → 0.24.1Breaking1New5Changed3Fixed9Other5
BreakingUpgrade verdict
1 breaking change.
In plain terms
- The internal way operators transform streams was rewritten, which changes how some operators behave.
Must act 1 item needs code or config changes
What you must change
Breaking1
Refactors Stream transformer setup so operators implement Sink via Stream.eventTransformed, fixing incorrect operator behavior.
Stream.eventTransformedSinkAPI changes
Generated by DepDelta from published Dart source. Not mixed with prose notes.
- changed:
class DefaultIfEmptyStreamTransformer<T> extends StreamTransformerBase<T, T> → class DefaultIfEmptyStreamTransformer<S> extends StreamTransformerBase<S, S> - changed:
class DelayStreamTransformer<T> extends StreamTransformerBase<T, T> → class DelayStreamTransformer<S> extends StreamTransformerBase<S, S> - changed:
class DematerializeStreamTransformer<T> extends StreamTransformerBase<Notification<T>, T> → class DematerializeStreamTransformer<S> extends StreamTransformerBase<Notification<S>, S> - changed:
class DistinctUniqueStreamTransformer<T> extends StreamTransformerBase<T, T> → class DistinctUniqueStreamTransformer<S> extends StreamTransformerBase<S, S> - changed:
class DoStreamTransformer<T> extends StreamTransformerBase<T, T> → class DoStreamTransformer<S> extends StreamTransformerBase<S, S> - changed:
class ExhaustMapStreamTransformer<T, S> extends StreamTransformerBase<T, S> → class ExhaustMapStreamTransformer<S, T> extends StreamTransformerBase<S, T> - changed:
class FlatMapStreamTransformer<T, S> extends StreamTransformerBase<T, S> → class FlatMapStreamTransformer<S, T> extends StreamTransformerBase<S, T> - changed:
class GroupByStreamTransformer<T, S> extends StreamTransformerBase<T, GroupByStream<T, S>> → class GroupByStreamTransformer<S, T> extends StreamTransformerBase<S, GroupByStream<S, T>> - changed:
class IgnoreElementsStreamTransformer<T> extends StreamTransformerBase<T, T> → class IgnoreElementsStreamTransformer<S> extends StreamTransformerBase<S, S> - changed:
class IntervalStreamTransformer<T> extends StreamTransformerBase<T, T> → class IntervalStreamTransformer<S> extends StreamTransformerBase<S, S> - changed:
class MaterializeStreamTransformer<T> extends StreamTransformerBase<T, Notification<T>> → class MaterializeStreamTransformer<S> extends StreamTransformerBase<S, Notification<S>> - changed:
class OnErrorResumeStreamTransformer<T> extends StreamTransformerBase<T, T> → class OnErrorResumeStreamTransformer<S> extends StreamTransformerBase<S, S> - changed:
class ScanStreamTransformer<T, S> extends StreamTransformerBase<T, S> → class ScanStreamTransformer<S, T> extends StreamTransformerBase<S, T> - changed:
class SkipUntilStreamTransformer<T, S> extends StreamTransformerBase<T, T> → class SkipUntilStreamTransformer<S, T> extends StreamTransformerBase<S, S> - changed:
class StartWithManyStreamTransformer<T> extends StreamTransformerBase<T, T> → class StartWithManyStreamTransformer<S> extends StreamTransformerBase<S, S> - changed:
class StartWithStreamTransformer<T> extends StreamTransformerBase<T, T> → class StartWithStreamTransformer<S> extends StreamTransformerBase<S, S> - changed:
class SwitchIfEmptyStreamTransformer<T> extends StreamTransformerBase<T, T> → class SwitchIfEmptyStreamTransformer<S> extends StreamTransformerBase<S, S> - changed:
class SwitchMapStreamTransformer<T, S> extends StreamTransformerBase<T, S> → class SwitchMapStreamTransformer<S, T> extends StreamTransformerBase<S, T> - changed:
class TakeUntilStreamTransformer<T, S> extends StreamTransformerBase<T, T> → class TakeUntilStreamTransformer<S, T> extends StreamTransformerBase<S, S> - changed:
class TimeIntervalStreamTransformer<T> extends StreamTransformerBase<T, TimeInterval<T>> → class TimeIntervalStreamTransformer<S> extends StreamTransformerBase<S, TimeInterval<S>> - changed:
class TimestampStreamTransformer<T> extends StreamTransformerBase<T, Timestamped<T>> → class TimestampStreamTransformer<S> extends StreamTransformerBase<S, Timestamped<S>> - changed:
class WithLatestFromStreamTransformer<T, S, R> extends StreamTransformerBase<T, R> → class WithLatestFromStreamTransformer<S, T, R> extends StreamTransformerBase<S, R> - changed:
ctor DefaultIfEmptyStreamTransformer(T defaultValue) → ctor DefaultIfEmptyStreamTransformer(this.defaultValue) - changed:
ctor DelayStreamTransformer(Duration duration) → ctor DelayStreamTransformer(this.duration) - changed:
ctor DistinctUniqueStreamTransformer( {bool Function(T e1, T e2) equals, int Function(T e) hashCode}) → ctor DistinctUniqueStreamTransformer({this.equals, this.hashCodeMethod}) - changed:
ctor DoStreamTransformer( {dynamic Function() onCancel, void Function(T event) onData, void Function() onDone, void Function(Notification<T> notification) onEach, Function onError, void Function() onListen, void Function(Future<dynamic> resumeSignal) onPause, void Function() onResume}) → ctor DoStreamTransformer( {this.onCancel, this.onData, this.onDone, this.onEach, this.onError, this.onListen, this.onPause, this.onResume}) - changed:
ctor ExhaustMapStreamTransformer(Stream<S> Function(T value) mapper) → ctor ExhaustMapStreamTransformer(this.mapper) - changed:
ctor FlatMapStreamTransformer(Stream<S> Function(T value) mapper) → ctor FlatMapStreamTransformer(this.mapper) - changed:
ctor GroupByStreamTransformer(S Function(T event) grouper) → ctor GroupByStreamTransformer(this.grouper) - changed:
ctor IntervalStreamTransformer(Duration duration) → ctor IntervalStreamTransformer(this.duration) - changed:
ctor MapToStreamTransformer(T value) → ctor MapToStreamTransformer(this.value) - changed:
ctor OnErrorResumeStreamTransformer(Stream<T> Function(dynamic error) recoveryFn) → ctor OnErrorResumeStreamTransformer(this.recoveryFn) - changed:
ctor PublishConnectableStream(Stream<T> source) → ctor PublishConnectableStream(Stream<T> source, {bool sync = …}) - changed:
ctor ReplayConnectableStream(Stream<T> stream, {int maxSize}) → ctor ReplayConnectableStream(Stream<T> stream, {int maxSize, bool sync = …}) - changed:
ctor ScanStreamTransformer( S Function(S accumulated, T value, int index) accumulator, [S seed]) → ctor ScanStreamTransformer(this.accumulator, [this.seed]) - changed:
ctor SkipUntilStreamTransformer(Stream<S> otherStream) → ctor SkipUntilStreamTransformer(this.otherStream) - changed:
ctor StartWithManyStreamTransformer(Iterable<T> startValues) → ctor StartWithManyStreamTransformer(this.startValues) - changed:
ctor StartWithStreamTransformer(T startValue) → ctor StartWithStreamTransformer(this.startValue, {this.sync = …}) - changed:
ctor SwitchIfEmptyStreamTransformer(Stream<T> fallbackStream) → ctor SwitchIfEmptyStreamTransformer(this.fallbackStream) - changed:
ctor SwitchMapStreamTransformer(Stream<S> Function(T value) mapper) → ctor SwitchMapStreamTransformer(this.mapper) - changed:
ctor TakeUntilStreamTransformer(Stream<S> otherStream) → ctor TakeUntilStreamTransformer(this.otherStream) - changed:
ctor ValueConnectableStream(Stream<T> source) → ctor ValueConnectableStream(Stream<T> source, {bool sync = …}) - changed:
ctor ValueConnectableStream.seeded( Stream<T> source, T seedValue, ) → ctor ValueConnectableStream.seeded(Stream<T> source, T seedValue, {bool sync = …}) - changed:
ctor WithLatestFromStreamTransformer( Iterable<Stream<S>> latestFromStreams, R Function(T t, List<S> values) fn) → ctor WithLatestFromStreamTransformer(this.latestFromStreams, this.combiner) - changed:
extension MapToExtension<T> on Stream<T> → extension MapToExtension<S> on Stream<S> - changed:
method DefaultIfEmptyStreamTransformer.bind(Stream<T> stream): Stream<T> → method DefaultIfEmptyStreamTransformer.bind(Stream<S> stream): Stream<S> - changed:
method DelayStreamTransformer.bind(Stream<T> stream): Stream<T> → method DelayStreamTransformer.bind(Stream<S> stream): Stream<S> - changed:
method DematerializeStreamTransformer.bind(Stream<Notification<T>> stream): Stream<T> → method DematerializeStreamTransformer.bind(Stream<Notification<S>> stream): Stream<S> - changed:
method DistinctUniqueStreamTransformer.bind(Stream<T> stream): Stream<T> → method DistinctUniqueStreamTransformer.bind(Stream<S> stream): Stream<S> - changed:
method DoStreamTransformer.bind(Stream<T> stream): Stream<T> → method DoStreamTransformer.bind(Stream<S> stream): Stream<S> - changed:
method ExhaustMapStreamTransformer.bind(Stream<T> stream): Stream<S> → method ExhaustMapStreamTransformer.bind(Stream<S> stream): Stream<T> - changed:
method FlatMapStreamTransformer.bind(Stream<T> stream): Stream<S> → method FlatMapStreamTransformer.bind(Stream<S> stream): Stream<T> - changed:
method GroupByStreamTransformer.bind(Stream<T> stream): Stream<GroupByStream<T, S>> → method GroupByStreamTransformer.bind(Stream<S> stream): Stream<GroupByStream<S, T>> - changed:
method IgnoreElementsStreamTransformer.bind(Stream<T> stream): Stream<T> → method IgnoreElementsStreamTransformer.bind(Stream<S> stream): Stream<S> - changed:
method IntervalStreamTransformer.bind(Stream<T> stream): Stream<T> → method IntervalStreamTransformer.bind(Stream<S> stream): Stream<S> - changed:
method MapToExtension.mapTo<S>(S value): Stream<S> → method MapToExtension.mapTo<T>(T value): Stream<T> - changed:
method MaterializeStreamTransformer.bind(Stream<T> stream): Stream<Notification<T>> → method MaterializeStreamTransformer.bind(Stream<S> stream): Stream<Notification<S>> - changed:
method OnErrorResumeStreamTransformer.bind(Stream<T> stream): Stream<T> → method OnErrorResumeStreamTransformer.bind(Stream<S> stream): Stream<S> - changed:
method ScanStreamTransformer.bind(Stream<T> stream): Stream<S> → method ScanStreamTransformer.bind(Stream<S> stream): Stream<T> - changed:
method SkipUntilStreamTransformer.bind(Stream<T> stream): Stream<T> → method SkipUntilStreamTransformer.bind(Stream<S> stream): Stream<S> - changed:
method StartWithManyStreamTransformer.bind(Stream<T> stream): Stream<T> → method StartWithManyStreamTransformer.bind(Stream<S> stream): Stream<S> - changed:
method StartWithStreamTransformer.bind(Stream<T> stream): Stream<T> → method StartWithStreamTransformer.bind(Stream<S> stream): Stream<S> - changed:
method SwitchIfEmptyStreamTransformer.bind(Stream<T> stream): Stream<T> → method SwitchIfEmptyStreamTransformer.bind(Stream<S> stream): Stream<S> - changed:
method SwitchMapStreamTransformer.bind(Stream<T> stream): Stream<S> → method SwitchMapStreamTransformer.bind(Stream<S> stream): Stream<T> - changed:
method TakeUntilStreamTransformer.bind(Stream<T> stream): Stream<T> → method TakeUntilStreamTransformer.bind(Stream<S> stream): Stream<S> - changed:
method TimeIntervalStreamTransformer.bind(Stream<T> stream): Stream<TimeInterval<T>> → method TimeIntervalStreamTransformer.bind(Stream<S> stream): Stream<TimeInterval<S>> - changed:
method TimestampStreamTransformer.bind(Stream<T> stream): Stream<Timestamped<T>> → method TimestampStreamTransformer.bind(Stream<S> stream): Stream<Timestamped<S>> - changed:
method WithLatestFromStreamTransformer.bind(Stream<T> stream): Stream<R> → method WithLatestFromStreamTransformer.bind(Stream<S> stream): Stream<R> - added:
class EndWithManyStreamTransformer<S> extends StreamTransformerBase<S, S> - added:
class EndWithStreamTransformer<S> extends StreamTransformerBase<S, S> - added:
class TakeWhileInclusiveStreamTransformer<S> extends StreamTransformerBase<S, S> - added:
ctor EndWithManyStreamTransformer(this.endValues) - added:
ctor EndWithStreamTransformer(this.endValue) - added:
ctor TakeWhileInclusiveStreamTransformer(this.test) - added:
extension AddToCompositeSubscriptionExtension<T> on StreamSubscription<T> - added:
extension EndWithExtension<T> on Stream<T> - added:
extension EndWithManyExtension<T> on Stream<T> - added:
extension TakeWhileInclusiveExtension<T> on Stream<T> - added:
field DefaultIfEmptyStreamTransformer.defaultValue: final S - added:
field DelayStreamTransformer.duration: final Duration - added:
field DoStreamTransformer.onError: final Function - added:
field EndWithManyStreamTransformer.endValues: final Iterable<S> - added:
field EndWithStreamTransformer.endValue: final S - added:
field IntervalStreamTransformer.duration: final Duration - added:
field MapToStreamTransformer.value: final T - added:
field ScanStreamTransformer.seed: final T - added:
field SkipUntilStreamTransformer.otherStream: final Stream<T> - added:
field StartWithManyStreamTransformer.startValues: final Iterable<S> - added:
field StartWithStreamTransformer.startValue: final S - added:
field StartWithStreamTransformer.sync: final bool - added:
field SwitchIfEmptyStreamTransformer.fallbackStream: final Stream<S> - added:
field TakeUntilStreamTransformer.otherStream: final Stream<T> - added:
field WithLatestFromStreamTransformer.latestFromStreams: final Iterable<Stream<T>> - added:
get CompositeSubscription.allPaused: bool - added:
get CompositeSubscription.isEmpty: bool - added:
get CompositeSubscription.isNotEmpty: bool - added:
get CompositeSubscription.length: int - added:
get ReplayConnectableStream.errors: List<Object> - added:
get ReplayStream.errors: List<Object> - added:
get ReplaySubject.errors: List<Object> - added:
method AddToCompositeSubscriptionExtension.addTo(CompositeSubscription compositeSubscription): void - added:
method CompositeSubscription.pauseAll([Future resumeSignal]): void - added:
method CompositeSubscription.resumeAll(): void - added:
method DistinctUniqueStreamTransformer.Function(S e): int - added:
method DistinctUniqueStreamTransformer.Function(S e1, S e2): bool - added:
method DoStreamTransformer.Function(): dynamic - added:
method DoStreamTransformer.Function(): void - added:
method DoStreamTransformer.Function(Future<dynamic> resumeSignal): void - added:
method DoStreamTransformer.Function(Notification<S> notification): void - added:
method DoStreamTransformer.Function(S event): void - added:
method EndWithExtension.endWith(T endValue): Stream<T> - added:
method EndWithManyExtension.endWithMany(Iterable<T> endValues): Stream<T> - added:
method EndWithManyStreamTransformer.bind(Stream<S> stream): Stream<S> - added:
method EndWithStreamTransformer.bind(Stream<S> stream): Stream<S> - added:
method ExhaustMapStreamTransformer.Function(S value): Stream<T> - added:
method FlatMapStreamTransformer.Function(S value): Stream<T> - added:
method GroupByStreamTransformer.Function(S event): T - added:
method OnErrorResumeStreamTransformer.Function(Object error): Stream<S> - added:
method ReplaySubject.onAddError(Object error, [StackTrace stackTrace]): void - added:
method ScanStreamTransformer.Function(T accumulated, S value, int index): T - added:
method SwitchMapStreamTransformer.Function(S value): Stream<T> - added:
method TakeWhileInclusiveExtension.takeWhileInclusive(bool Function(T) test): Stream<T> - added:
method TakeWhileInclusiveStreamTransformer.Function(S): bool - added:
method TakeWhileInclusiveStreamTransformer.bind(Stream<S> stream): Stream<S> - added:
method WithLatestFromStreamTransformer.Function(S t, List<T> values): R
- changed:
ctor PublishConnectableStream(Stream<T> source) → ctor PublishConnectableStream(Stream<T> source, {bool sync = …}) - changed:
ctor ReplayConnectableStream(Stream<T> stream, {int maxSize}) → ctor ReplayConnectableStream(Stream<T> stream, {int maxSize, bool sync = …}) - changed:
ctor ValueConnectableStream(Stream<T> source) → ctor ValueConnectableStream(Stream<T> source, {bool sync = …}) - changed:
ctor ValueConnectableStream.seeded( Stream<T> source, T seedValue, ) → ctor ValueConnectableStream.seeded(Stream<T> source, T seedValue, {bool sync = …}) - added:
get ReplayConnectableStream.errors: List<Object> - added:
get ReplayStream.errors: List<Object>
- added:
get ReplaySubject.errors: List<Object> - added:
method ReplaySubject.onAddError(Object error, [StackTrace stackTrace]): void
- changed:
class DefaultIfEmptyStreamTransformer<T> extends StreamTransformerBase<T, T> → class DefaultIfEmptyStreamTransformer<S> extends StreamTransformerBase<S, S> - changed:
class DelayStreamTransformer<T> extends StreamTransformerBase<T, T> → class DelayStreamTransformer<S> extends StreamTransformerBase<S, S> - changed:
class DematerializeStreamTransformer<T> extends StreamTransformerBase<Notification<T>, T> → class DematerializeStreamTransformer<S> extends StreamTransformerBase<Notification<S>, S> - changed:
class DistinctUniqueStreamTransformer<T> extends StreamTransformerBase<T, T> → class DistinctUniqueStreamTransformer<S> extends StreamTransformerBase<S, S> - changed:
class DoStreamTransformer<T> extends StreamTransformerBase<T, T> → class DoStreamTransformer<S> extends StreamTransformerBase<S, S> - changed:
class ExhaustMapStreamTransformer<T, S> extends StreamTransformerBase<T, S> → class ExhaustMapStreamTransformer<S, T> extends StreamTransformerBase<S, T> - changed:
class FlatMapStreamTransformer<T, S> extends StreamTransformerBase<T, S> → class FlatMapStreamTransformer<S, T> extends StreamTransformerBase<S, T> - changed:
class GroupByStreamTransformer<T, S> extends StreamTransformerBase<T, GroupByStream<T, S>> → class GroupByStreamTransformer<S, T> extends StreamTransformerBase<S, GroupByStream<S, T>> - changed:
class IgnoreElementsStreamTransformer<T> extends StreamTransformerBase<T, T> → class IgnoreElementsStreamTransformer<S> extends StreamTransformerBase<S, S> - changed:
class IntervalStreamTransformer<T> extends StreamTransformerBase<T, T> → class IntervalStreamTransformer<S> extends StreamTransformerBase<S, S> - changed:
class MaterializeStreamTransformer<T> extends StreamTransformerBase<T, Notification<T>> → class MaterializeStreamTransformer<S> extends StreamTransformerBase<S, Notification<S>> - changed:
class OnErrorResumeStreamTransformer<T> extends StreamTransformerBase<T, T> → class OnErrorResumeStreamTransformer<S> extends StreamTransformerBase<S, S> - changed:
class ScanStreamTransformer<T, S> extends StreamTransformerBase<T, S> → class ScanStreamTransformer<S, T> extends StreamTransformerBase<S, T> - changed:
class SkipUntilStreamTransformer<T, S> extends StreamTransformerBase<T, T> → class SkipUntilStreamTransformer<S, T> extends StreamTransformerBase<S, S> - changed:
class StartWithManyStreamTransformer<T> extends StreamTransformerBase<T, T> → class StartWithManyStreamTransformer<S> extends StreamTransformerBase<S, S> - changed:
class StartWithStreamTransformer<T> extends StreamTransformerBase<T, T> → class StartWithStreamTransformer<S> extends StreamTransformerBase<S, S> - changed:
class SwitchIfEmptyStreamTransformer<T> extends StreamTransformerBase<T, T> → class SwitchIfEmptyStreamTransformer<S> extends StreamTransformerBase<S, S> - changed:
class SwitchMapStreamTransformer<T, S> extends StreamTransformerBase<T, S> → class SwitchMapStreamTransformer<S, T> extends StreamTransformerBase<S, T> - changed:
class TakeUntilStreamTransformer<T, S> extends StreamTransformerBase<T, T> → class TakeUntilStreamTransformer<S, T> extends StreamTransformerBase<S, S> - changed:
class TimeIntervalStreamTransformer<T> extends StreamTransformerBase<T, TimeInterval<T>> → class TimeIntervalStreamTransformer<S> extends StreamTransformerBase<S, TimeInterval<S>> - changed:
class TimestampStreamTransformer<T> extends StreamTransformerBase<T, Timestamped<T>> → class TimestampStreamTransformer<S> extends StreamTransformerBase<S, Timestamped<S>> - changed:
class WithLatestFromStreamTransformer<T, S, R> extends StreamTransformerBase<T, R> → class WithLatestFromStreamTransformer<S, T, R> extends StreamTransformerBase<S, R> - changed:
ctor DefaultIfEmptyStreamTransformer(T defaultValue) → ctor DefaultIfEmptyStreamTransformer(this.defaultValue) - changed:
ctor DelayStreamTransformer(Duration duration) → ctor DelayStreamTransformer(this.duration) - changed:
ctor DistinctUniqueStreamTransformer( {bool Function(T e1, T e2) equals, int Function(T e) hashCode}) → ctor DistinctUniqueStreamTransformer({this.equals, this.hashCodeMethod}) - changed:
ctor DoStreamTransformer( {dynamic Function() onCancel, void Function(T event) onData, void Function() onDone, void Function(Notification<T> notification) onEach, Function onError, void Function() onListen, void Function(Future<dynamic> resumeSignal) onPause, void Function() onResume}) → ctor DoStreamTransformer( {this.onCancel, this.onData, this.onDone, this.onEach, this.onError, this.onListen, this.onPause, this.onResume}) - changed:
ctor ExhaustMapStreamTransformer(Stream<S> Function(T value) mapper) → ctor ExhaustMapStreamTransformer(this.mapper) - changed:
ctor FlatMapStreamTransformer(Stream<S> Function(T value) mapper) → ctor FlatMapStreamTransformer(this.mapper) - changed:
ctor GroupByStreamTransformer(S Function(T event) grouper) → ctor GroupByStreamTransformer(this.grouper) - changed:
ctor IntervalStreamTransformer(Duration duration) → ctor IntervalStreamTransformer(this.duration) - changed:
ctor MapToStreamTransformer(T value) → ctor MapToStreamTransformer(this.value) - changed:
ctor OnErrorResumeStreamTransformer(Stream<T> Function(dynamic error) recoveryFn) → ctor OnErrorResumeStreamTransformer(this.recoveryFn) - changed:
ctor ScanStreamTransformer( S Function(S accumulated, T value, int index) accumulator, [S seed]) → ctor ScanStreamTransformer(this.accumulator, [this.seed]) - changed:
ctor SkipUntilStreamTransformer(Stream<S> otherStream) → ctor SkipUntilStreamTransformer(this.otherStream) - changed:
ctor StartWithManyStreamTransformer(Iterable<T> startValues) → ctor StartWithManyStreamTransformer(this.startValues) - changed:
ctor StartWithStreamTransformer(T startValue) → ctor StartWithStreamTransformer(this.startValue, {this.sync = …}) - changed:
ctor SwitchIfEmptyStreamTransformer(Stream<T> fallbackStream) → ctor SwitchIfEmptyStreamTransformer(this.fallbackStream) - changed:
ctor SwitchMapStreamTransformer(Stream<S> Function(T value) mapper) → ctor SwitchMapStreamTransformer(this.mapper) - changed:
ctor TakeUntilStreamTransformer(Stream<S> otherStream) → ctor TakeUntilStreamTransformer(this.otherStream) - changed:
ctor WithLatestFromStreamTransformer( Iterable<Stream<S>> latestFromStreams, R Function(T t, List<S> values) fn) → ctor WithLatestFromStreamTransformer(this.latestFromStreams, this.combiner) - changed:
extension MapToExtension<T> on Stream<T> → extension MapToExtension<S> on Stream<S> - changed:
method DefaultIfEmptyStreamTransformer.bind(Stream<T> stream): Stream<T> → method DefaultIfEmptyStreamTransformer.bind(Stream<S> stream): Stream<S> - changed:
method DelayStreamTransformer.bind(Stream<T> stream): Stream<T> → method DelayStreamTransformer.bind(Stream<S> stream): Stream<S> - changed:
method DematerializeStreamTransformer.bind(Stream<Notification<T>> stream): Stream<T> → method DematerializeStreamTransformer.bind(Stream<Notification<S>> stream): Stream<S> - changed:
method DistinctUniqueStreamTransformer.bind(Stream<T> stream): Stream<T> → method DistinctUniqueStreamTransformer.bind(Stream<S> stream): Stream<S> - changed:
method DoStreamTransformer.bind(Stream<T> stream): Stream<T> → method DoStreamTransformer.bind(Stream<S> stream): Stream<S> - changed:
method ExhaustMapStreamTransformer.bind(Stream<T> stream): Stream<S> → method ExhaustMapStreamTransformer.bind(Stream<S> stream): Stream<T> - changed:
method FlatMapStreamTransformer.bind(Stream<T> stream): Stream<S> → method FlatMapStreamTransformer.bind(Stream<S> stream): Stream<T> - changed:
method GroupByStreamTransformer.bind(Stream<T> stream): Stream<GroupByStream<T, S>> → method GroupByStreamTransformer.bind(Stream<S> stream): Stream<GroupByStream<S, T>> - changed:
method IgnoreElementsStreamTransformer.bind(Stream<T> stream): Stream<T> → method IgnoreElementsStreamTransformer.bind(Stream<S> stream): Stream<S> - changed:
method IntervalStreamTransformer.bind(Stream<T> stream): Stream<T> → method IntervalStreamTransformer.bind(Stream<S> stream): Stream<S> - changed:
method MapToExtension.mapTo<S>(S value): Stream<S> → method MapToExtension.mapTo<T>(T value): Stream<T> - changed:
method MaterializeStreamTransformer.bind(Stream<T> stream): Stream<Notification<T>> → method MaterializeStreamTransformer.bind(Stream<S> stream): Stream<Notification<S>> - changed:
method OnErrorResumeStreamTransformer.bind(Stream<T> stream): Stream<T> → method OnErrorResumeStreamTransformer.bind(Stream<S> stream): Stream<S> - changed:
method ScanStreamTransformer.bind(Stream<T> stream): Stream<S> → method ScanStreamTransformer.bind(Stream<S> stream): Stream<T> - changed:
method SkipUntilStreamTransformer.bind(Stream<T> stream): Stream<T> → method SkipUntilStreamTransformer.bind(Stream<S> stream): Stream<S> - changed:
method StartWithManyStreamTransformer.bind(Stream<T> stream): Stream<T> → method StartWithManyStreamTransformer.bind(Stream<S> stream): Stream<S> - changed:
method StartWithStreamTransformer.bind(Stream<T> stream): Stream<T> → method StartWithStreamTransformer.bind(Stream<S> stream): Stream<S> - changed:
method SwitchIfEmptyStreamTransformer.bind(Stream<T> stream): Stream<T> → method SwitchIfEmptyStreamTransformer.bind(Stream<S> stream): Stream<S> - changed:
method SwitchMapStreamTransformer.bind(Stream<T> stream): Stream<S> → method SwitchMapStreamTransformer.bind(Stream<S> stream): Stream<T> - changed:
method TakeUntilStreamTransformer.bind(Stream<T> stream): Stream<T> → method TakeUntilStreamTransformer.bind(Stream<S> stream): Stream<S> - changed:
method TimeIntervalStreamTransformer.bind(Stream<T> stream): Stream<TimeInterval<T>> → method TimeIntervalStreamTransformer.bind(Stream<S> stream): Stream<TimeInterval<S>> - changed:
method TimestampStreamTransformer.bind(Stream<T> stream): Stream<Timestamped<T>> → method TimestampStreamTransformer.bind(Stream<S> stream): Stream<Timestamped<S>> - changed:
method WithLatestFromStreamTransformer.bind(Stream<T> stream): Stream<R> → method WithLatestFromStreamTransformer.bind(Stream<S> stream): Stream<R> - added:
class EndWithManyStreamTransformer<S> extends StreamTransformerBase<S, S> - added:
class EndWithStreamTransformer<S> extends StreamTransformerBase<S, S> - added:
class TakeWhileInclusiveStreamTransformer<S> extends StreamTransformerBase<S, S> - added:
ctor EndWithManyStreamTransformer(this.endValues) - added:
ctor EndWithStreamTransformer(this.endValue) - added:
ctor TakeWhileInclusiveStreamTransformer(this.test) - added:
extension EndWithExtension<T> on Stream<T> - added:
extension EndWithManyExtension<T> on Stream<T> - added:
extension TakeWhileInclusiveExtension<T> on Stream<T> - added:
field DefaultIfEmptyStreamTransformer.defaultValue: final S - added:
field DelayStreamTransformer.duration: final Duration - added:
field DoStreamTransformer.onError: final Function - added:
field EndWithManyStreamTransformer.endValues: final Iterable<S> - added:
field EndWithStreamTransformer.endValue: final S - added:
field IntervalStreamTransformer.duration: final Duration - added:
field MapToStreamTransformer.value: final T - added:
field ScanStreamTransformer.seed: final T - added:
field SkipUntilStreamTransformer.otherStream: final Stream<T> - added:
field StartWithManyStreamTransformer.startValues: final Iterable<S> - added:
field StartWithStreamTransformer.startValue: final S - added:
field StartWithStreamTransformer.sync: final bool - added:
field SwitchIfEmptyStreamTransformer.fallbackStream: final Stream<S> - added:
field TakeUntilStreamTransformer.otherStream: final Stream<T> - added:
field WithLatestFromStreamTransformer.latestFromStreams: final Iterable<Stream<T>> - added:
method DistinctUniqueStreamTransformer.Function(S e): int - added:
method DistinctUniqueStreamTransformer.Function(S e1, S e2): bool - added:
method DoStreamTransformer.Function(): dynamic - added:
method DoStreamTransformer.Function(): void - added:
method DoStreamTransformer.Function(Future<dynamic> resumeSignal): void - added:
method DoStreamTransformer.Function(Notification<S> notification): void - added:
method DoStreamTransformer.Function(S event): void - added:
method EndWithExtension.endWith(T endValue): Stream<T> - added:
method EndWithManyExtension.endWithMany(Iterable<T> endValues): Stream<T> - added:
method EndWithManyStreamTransformer.bind(Stream<S> stream): Stream<S> - added:
method EndWithStreamTransformer.bind(Stream<S> stream): Stream<S> - added:
method ExhaustMapStreamTransformer.Function(S value): Stream<T> - added:
method FlatMapStreamTransformer.Function(S value): Stream<T> - added:
method GroupByStreamTransformer.Function(S event): T - added:
method OnErrorResumeStreamTransformer.Function(Object error): Stream<S> - added:
method ScanStreamTransformer.Function(T accumulated, S value, int index): T - added:
method SwitchMapStreamTransformer.Function(S value): Stream<T> - added:
method TakeWhileInclusiveExtension.takeWhileInclusive(bool Function(T) test): Stream<T> - added:
method TakeWhileInclusiveStreamTransformer.Function(S): bool - added:
method TakeWhileInclusiveStreamTransformer.bind(Stream<S> stream): Stream<S> - added:
method WithLatestFromStreamTransformer.Function(S t, List<T> values): R