Upgrading rxdart 0.8 to 0.9
Breaking0.8.3+1 → 0.9.0Breaking3Changed1Other1
BreakingUpgrade verdict
3 breaking changes.
In plain terms
- Transformers are now real classes instead of factory functions, and each one can be reused more than once.
- Retry is no longer a stream operator; you now create it as a constructor so retries rebuild the stream correctly.
- Streams that allow only one listener now correctly reject a second listener.
Must act 3 items need code or config changes
What you must change
Breaking3
Converts all StreamTransformer factories to proper classes that can be re-used multiple times.
StreamTransformerMoves Retry from an operator to a constructor so the stream can be properly re-constructed each time.
RetryStreams now properly enforce the single-subscription contract.
API changes
Generated by DepDelta from published Dart source. Not mixed with prose notes.
- removed:
class RetryError extends Error - removed:
ctor RetryError(this.count) - removed:
field AmbStream.streams: final Iterable<Stream<T>> - removed:
field CombineLatestStream.predicate: final Function - removed:
field CombineLatestStream.streams: final Iterable<Stream<dynamic>> - removed:
field ConcatEagerStream.streams: final Iterable<Stream<T>> - removed:
field ConcatStream.streams: final Iterable<Stream<T>> - removed:
field DeferStream.streamProvider: final StreamProvider<T> - removed:
field MergeStream.streams: final Iterable<Stream<T>> - removed:
field RetryError.count: final int - removed:
field RetryError.message: String - removed:
field TweenStream.changeInTime: final double - removed:
field TweenStream.duration: final Duration - removed:
field TweenStream.ease: final Ease - removed:
field TweenStream.intervalMs: final int - removed:
field TweenStream.startValue: final double - removed:
field ZipStream.predicate: final Function - removed:
field ZipStream.streams: final Iterable<Stream<dynamic>> - removed:
function bufferWithCountTransformer<T, S extends List<T>>( int count, [int skip]): StreamTransformer<T, S> - removed:
function callTransformer<T>( {void onCancel(), void onData(T event), void onDone(), void onEach(Notification<T> notification), Function onError, void onListen(), void onPause(Future<dynamic> resumeSignal), void onResume()}): StreamTransformer<T, T> - removed:
function concatMapTransformer<T, S>( Stream<S> predicate(T value)): StreamTransformer<T, S> - removed:
function debounceTransformer<T>(Duration duration): StreamTransformer<T, T> - removed:
function defaultIfEmptyTransformer<T>(T defaultValue): StreamTransformer<T, T> - removed:
function dematerializeTransformer<T>(): StreamTransformer<Notification<T>, T> - removed:
function flatMapLatestTransformer<T, S>( Stream<S> predicate(T value)): StreamTransformer<T, S> - removed:
function flatMapTransformer<T, S>(Stream<S> predicate(T value)): StreamTransformer<T, S> - removed:
function groupByTransformer<T, S>( S keySelector(T value), {int compareKeys(S keyA, S keyB) = …}): StreamTransformer<T, GroupByMap<S, T>> - removed:
function ignoreElementsTransformer<T>(): StreamTransformer<T, T> - removed:
function intervalTransformer<T>(Duration duration): StreamTransformer<T, T> - removed:
function materializeTransformer<T>(): StreamTransformer<T, Notification<T>> - removed:
function maxTransformer<T>([int compare(T a, T b)]): StreamTransformer<T, T> - removed:
function minTransformer<T>([int compare(T a, T b)]): StreamTransformer<T, T> - removed:
function ofTypeTransformer<T, S>(TypeToken<S> typeToken): StreamTransformer<T, S> - removed:
function onErrorResumeNextTransformer<T>( Stream<T> recoveryStream): StreamTransformer<T, T> - removed:
function repeatTransformer<T>(int repeatCount): StreamTransformer<T, T> - removed:
function retryTransformer<T>(int count): StreamTransformer<T, T> - removed:
function sampleTransformer<T>(Stream<dynamic> sampleStream): StreamTransformer<T, T> - removed:
function scanTransformer<T, S>( S predicate(S accumulated, T value, int index), [S seed]): StreamTransformer<T, S> - removed:
function startWithManyTransformer<T>(List<T> startValues): StreamTransformer<T, T> - removed:
function startWithTransformer<T>(T startValue): StreamTransformer<T, T> - removed:
function switchIfEmptyTransformer<T>(Stream<T> fallbackStream): StreamTransformer<T, T> - removed:
function takeUntilTransformer<T, S>(Stream<S> otherStream): StreamTransformer<T, T> - removed:
function throttleTransformer<T>(Duration duration): StreamTransformer<T, T> - removed:
function timeIntervalTransformer<T, S extends TimeInterval<T>>(): StreamTransformer<T, S> - removed:
function timestampTransformer<T>(): StreamTransformer<T, Timestamped<T>> - removed:
function windowWithCountTransformer<T, S extends Stream<T>>( int count, [int skip]): StreamTransformer<T, S> - removed:
function withLatestFromTransformer<T, S, R>( Stream<S> latestFromStream, R fn(T t, S s)): StreamTransformer<T, R> - removed:
method Observable.retry([int count]): Observable<T> - removed:
method RetryError.toString(): String - removed:
typedef Stream<T> StreamProvider<T>() - changed:
ctor AmbStream(this.streams) → ctor AmbStream(Iterable<Stream<T>> streams) - changed:
ctor CombineLatestStream(this.streams, this.predicate) → ctor CombineLatestStream(Iterable<Stream<dynamic>> streams, Function predicate) - changed:
ctor ConcatEagerStream(this.streams) → ctor ConcatEagerStream(Iterable<Stream<T>> streams) - changed:
ctor ConcatStream(this.streams) → ctor ConcatStream(Iterable<Stream<T>> streams) - changed:
ctor DeferStream(this.streamProvider) → ctor DeferStream(this.streamFactory) - changed:
ctor MergeStream(this.streams) → ctor MergeStream(Iterable<Stream<T>> streams) - changed:
ctor Observable.defer(Stream<T> createStream()) → ctor Observable.defer(Stream<T> streamFactory()) - changed:
ctor TweenStream(this.startValue, this.changeInTime, this.duration, this.intervalMs, this.ease) → ctor TweenStream(double startValue, double changeInTime, Duration duration, int intervalMs, Ease ease) - changed:
ctor ZipStream(this.streams, this.predicate) → ctor ZipStream(Iterable<Stream<dynamic>> streams, Function predicate) - changed:
method Observable.skipUntil(Stream<dynamic> otherStream): Observable<T> → method Observable.skipUntil<S>(Stream<S> otherStream): Observable<T> - changed:
method Observable.takeUntil(Stream<dynamic> otherStream): Observable<T> → method Observable.takeUntil<S>(Stream<S> otherStream): Observable<T> - added:
class BufferWithCountStreamTransformer<T, S extends List<T>> implements StreamTransformer<T, S> - added:
class CallStreamTransformer<T> implements StreamTransformer<T, T> - added:
class ConcatMapStreamTransformer<T, S> implements StreamTransformer<T, S> - added:
class DebounceStreamTransformer<T> implements StreamTransformer<T, T> - added:
class DefaultIfEmptyStreamTransformer<T> implements StreamTransformer<T, T> - added:
class DematerializeStreamTransformer<T> implements StreamTransformer<Notification<T>, T> - added:
class FlatMapLatestStreamTransformer<T, S> implements StreamTransformer<T, S> - added:
class FlatMapStreamTransformer<T, S> implements StreamTransformer<T, S> - added:
class GroupByStreamTransformer<T, S> implements StreamTransformer<T, GroupByMap<S, T>> - added:
class IgnoreElementsStreamTransformer<T> implements StreamTransformer<T, T> - added:
class IntervalStreamTransformer<T> implements StreamTransformer<T, T> - added:
class MaterializeStreamTransformer<T> implements StreamTransformer<T, Notification<T>> - added:
class MaxStreamTransformer<T> implements StreamTransformer<T, T> - added:
class MinStreamTransformer<T> implements StreamTransformer<T, T> - added:
class OfTypeStreamTransformer<T, S> implements StreamTransformer<T, S> - added:
class OnErrorResumeNextStreamTransformer<T> implements StreamTransformer<T, T> - added:
class RepeatStreamTransformer<T> implements StreamTransformer<T, T> - added:
class SampleStreamTransformer<T> implements StreamTransformer<T, T> - added:
class ScanStreamTransformer<T, S> implements StreamTransformer<T, S> - added:
class SkipUntilStreamTransformer<T, S> implements StreamTransformer<T, T> - added:
class StartWithManyStreamTransformer<T> implements StreamTransformer<T, T> - added:
class StartWithStreamTransformer<T> implements StreamTransformer<T, T> - added:
class SwitchIfEmptyStreamTransformer<T> implements StreamTransformer<T, T> - added:
class TakeUntilStreamTransformer<T, S> implements StreamTransformer<T, T> - added:
class ThrottleStreamTransformer<T> implements StreamTransformer<T, T> - added:
class TimeIntervalStreamTransformer<T, S extends TimeInterval<T>> implements StreamTransformer<T, S> - added:
class TimestampStreamTransformer<T> implements StreamTransformer<T, Timestamped<T>> - added:
class WindowWithCountStreamTransformer<T, S extends Stream<T>> implements StreamTransformer<T, S> - added:
class WithLatestFromStreamTransformer<T, S, R> implements StreamTransformer<T, R> - added:
ctor BufferWithCountStreamTransformer(this.count, [this.skip]) - added:
ctor CallStreamTransformer( {void onCancel(), void onData(T event), void onDone(), void onEach(Notification<T> notification), Function onError, void onListen(), void onPause(Future<dynamic> resumeSignal), void onResume()}) - added:
ctor ConcatMapStreamTransformer(Stream<S> predicate(T value)) - added:
ctor DebounceStreamTransformer(Duration duration) - added:
ctor DefaultIfEmptyStreamTransformer(T defaultValue) - added:
ctor DematerializeStreamTransformer() - added:
ctor FlatMapLatestStreamTransformer(Stream<S> predicate(T value)) - added:
ctor FlatMapStreamTransformer(Stream<S> predicate(T value)) - added:
ctor GroupByStreamTransformer(S keySelector(T value), {int compareKeys(S keyA, S keyB)}) - added:
ctor IgnoreElementsStreamTransformer() - added:
ctor IntervalStreamTransformer(Duration duration) - added:
ctor MaterializeStreamTransformer() - added:
ctor MaxStreamTransformer([this.compare]) - added:
ctor MinStreamTransformer([this.compare]) - added:
ctor Observable.retry(Stream<T> streamFactory(), [int count]) - added:
ctor OfTypeStreamTransformer(TypeToken<S> typeToken) - added:
ctor OnErrorResumeNextStreamTransformer(Stream<T> recoveryStream) - added:
ctor RepeatStreamTransformer(int repeatCount) - added:
ctor SampleStreamTransformer(Stream<dynamic> sampleStream) - added:
ctor ScanStreamTransformer(this.predicate, [this.seed]) - added:
ctor SkipUntilStreamTransformer(Stream<S> otherStream) - added:
ctor StartWithManyStreamTransformer(List<T> startValues) - added:
ctor StartWithStreamTransformer(T startValue) - added:
ctor SwitchIfEmptyStreamTransformer(Stream<T> fallbackStream) - added:
ctor TakeUntilStreamTransformer(Stream<S> otherStream) - added:
ctor ThrottleStreamTransformer(Duration duration) - added:
ctor TimeIntervalStreamTransformer() - added:
ctor TimestampStreamTransformer() - added:
ctor WindowWithCountStreamTransformer(int count, [int skip]) - added:
ctor WithLatestFromStreamTransformer(Stream<S> latestFromStream, R fn(T t, S s)) - added:
field AmbStream.controller: final StreamController<T> - added:
field BufferWithCountStreamTransformer.count: final int - added:
field BufferWithCountStreamTransformer.skip: final int - added:
field CallStreamTransformer.transformer: final StreamTransformer<T, T> - added:
field CombineLatestStream.controller: final StreamController<T> - added:
field ConcatEagerStream.controller: final StreamController<T> - added:
field ConcatMapStreamTransformer.transformer: final StreamTransformer<T, S> - added:
field ConcatStream.controller: final StreamController<T> - added:
field DebounceStreamTransformer.transformer: final StreamTransformer<T, T> - added:
field DefaultIfEmptyStreamTransformer.transformer: final StreamTransformer<T, T> - added:
field DeferStream.streamFactory: final StreamFactory<T> - added:
field DematerializeStreamTransformer.transformer: final StreamTransformer<Notification<T>, T> - added:
field ErrorStream.controller: StreamController<T> - added:
field FlatMapLatestStreamTransformer.transformer: final StreamTransformer<T, S> - added:
field FlatMapStreamTransformer.transformer: final StreamTransformer<T, S> - added:
field GroupByStreamTransformer.transformer: final StreamTransformer<T, GroupByMap<S, T>> - added:
field IgnoreElementsStreamTransformer.transformer: final StreamTransformer<T, T> - added:
field IntervalStreamTransformer.transformer: final StreamTransformer<T, T> - added:
field MaterializeStreamTransformer.transformer: final StreamTransformer<T, Notification<T>> - added:
field MaxStreamTransformer.compare: final _MaxStreamTransformerCompare<T> - added:
field MergeStream.controller: final StreamController<T> - added:
field MinStreamTransformer.compare: final _MinStreamTransformerCompare<T> - added:
field NeverStream.controller: StreamController<T> - added:
field OfTypeStreamTransformer.transformer: final StreamTransformer<T, S> - added:
field OnErrorResumeNextStreamTransformer.transformer: final StreamTransformer<T, T> - added:
field RepeatStreamTransformer.transformer: final StreamTransformer<T, T> - added:
field SampleStreamTransformer.transformer: final StreamTransformer<T, T> - added:
field ScanStreamTransformer.predicate: final _ScanStreamTransformerPredicate<T, S> - added:
field ScanStreamTransformer.seed: final S - added:
field SkipUntilStreamTransformer.transformer: final StreamTransformer<T, T> - added:
field StartWithManyStreamTransformer.transformer: final StreamTransformer<T, T> - added:
field StartWithStreamTransformer.transformer: final StreamTransformer<T, T> - added:
field SwitchIfEmptyStreamTransformer.transformer: final StreamTransformer<T, T> - added:
field TakeUntilStreamTransformer.transformer: final StreamTransformer<T, T> - added:
field ThrottleStreamTransformer.transformer: final StreamTransformer<T, T> - added:
field TimeIntervalStreamTransformer.transformer: final StreamTransformer<T, S> - added:
field TimerStream.controller: final StreamController<T> - added:
field TimestampStreamTransformer.transformer: final StreamTransformer<T, Timestamped<T>> - added:
field TweenStream.controller: final StreamController<double> - added:
field WindowWithCountStreamTransformer.transformer: final StreamTransformer<T, S> - added:
field WithLatestFromStreamTransformer.transformer: final StreamTransformer<T, R> - added:
field ZipStream.controller: final StreamController<T> - added:
method BufferWithCountStreamTransformer.bind(Stream<T> stream): Stream<S> - added:
method CallStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method ConcatMapStreamTransformer.bind(Stream<T> stream): Stream<S> - added:
method DebounceStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method DefaultIfEmptyStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method DematerializeStreamTransformer.bind(Stream<Notification<T>> stream): Stream<T> - added:
method FlatMapLatestStreamTransformer.bind(Stream<T> stream): Stream<S> - added:
method FlatMapStreamTransformer.bind(Stream<T> stream): Stream<S> - added:
method GroupByStreamTransformer.bind(Stream<T> stream): Stream<GroupByMap<S, T>> - added:
method IgnoreElementsStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method IntervalStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method MaterializeStreamTransformer.bind(Stream<T> stream): Stream<Notification<T>> - added:
method MaxStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method MinStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method OfTypeStreamTransformer.bind(Stream<T> stream): Stream<S> - added:
method OnErrorResumeNextStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method RepeatStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method SampleStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method ScanStreamTransformer.bind(Stream<T> stream): Stream<S> - added:
method SkipUntilStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method StartWithManyStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method StartWithStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method SwitchIfEmptyStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method TakeUntilStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method ThrottleStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method TimeIntervalStreamTransformer.bind(Stream<T> stream): Stream<S> - added:
method TimestampStreamTransformer.bind(Stream<T> stream): Stream<Timestamped<T>> - added:
method WindowWithCountStreamTransformer.bind(Stream<T> stream): Stream<S> - added:
method WithLatestFromStreamTransformer.bind(Stream<T> stream): Stream<R>
- removed:
field AmbStream.streams: final Iterable<Stream<T>> - removed:
field CombineLatestStream.predicate: final Function - removed:
field CombineLatestStream.streams: final Iterable<Stream<dynamic>> - removed:
field ConcatEagerStream.streams: final Iterable<Stream<T>> - removed:
field ConcatStream.streams: final Iterable<Stream<T>> - removed:
field DeferStream.streamProvider: final StreamProvider<T> - removed:
field MergeStream.streams: final Iterable<Stream<T>> - removed:
field TweenStream.changeInTime: final double - removed:
field TweenStream.duration: final Duration - removed:
field TweenStream.ease: final Ease - removed:
field TweenStream.intervalMs: final int - removed:
field TweenStream.startValue: final double - removed:
field ZipStream.predicate: final Function - removed:
field ZipStream.streams: final Iterable<Stream<dynamic>> - removed:
typedef Stream<T> StreamProvider<T>() - changed:
ctor AmbStream(this.streams) → ctor AmbStream(Iterable<Stream<T>> streams) - changed:
ctor CombineLatestStream(this.streams, this.predicate) → ctor CombineLatestStream(Iterable<Stream<dynamic>> streams, Function predicate) - changed:
ctor ConcatEagerStream(this.streams) → ctor ConcatEagerStream(Iterable<Stream<T>> streams) - changed:
ctor ConcatStream(this.streams) → ctor ConcatStream(Iterable<Stream<T>> streams) - changed:
ctor DeferStream(this.streamProvider) → ctor DeferStream(this.streamFactory) - changed:
ctor MergeStream(this.streams) → ctor MergeStream(Iterable<Stream<T>> streams) - changed:
ctor TweenStream(this.startValue, this.changeInTime, this.duration, this.intervalMs, this.ease) → ctor TweenStream(double startValue, double changeInTime, Duration duration, int intervalMs, Ease ease) - changed:
ctor ZipStream(this.streams, this.predicate) → ctor ZipStream(Iterable<Stream<dynamic>> streams, Function predicate) - added:
field AmbStream.controller: final StreamController<T> - added:
field CombineLatestStream.controller: final StreamController<T> - added:
field ConcatEagerStream.controller: final StreamController<T> - added:
field ConcatStream.controller: final StreamController<T> - added:
field DeferStream.streamFactory: final StreamFactory<T> - added:
field ErrorStream.controller: StreamController<T> - added:
field MergeStream.controller: final StreamController<T> - added:
field NeverStream.controller: StreamController<T> - added:
field TimerStream.controller: final StreamController<T> - added:
field TweenStream.controller: final StreamController<double> - added:
field ZipStream.controller: final StreamController<T>
- removed:
class RetryError extends Error - removed:
ctor RetryError(this.count) - removed:
field RetryError.count: final int - removed:
field RetryError.message: String - removed:
function bufferWithCountTransformer<T, S extends List<T>>( int count, [int skip]): StreamTransformer<T, S> - removed:
function callTransformer<T>( {void onCancel(), void onData(T event), void onDone(), void onEach(Notification<T> notification), Function onError, void onListen(), void onPause(Future<dynamic> resumeSignal), void onResume()}): StreamTransformer<T, T> - removed:
function concatMapTransformer<T, S>( Stream<S> predicate(T value)): StreamTransformer<T, S> - removed:
function debounceTransformer<T>(Duration duration): StreamTransformer<T, T> - removed:
function defaultIfEmptyTransformer<T>(T defaultValue): StreamTransformer<T, T> - removed:
function dematerializeTransformer<T>(): StreamTransformer<Notification<T>, T> - removed:
function flatMapLatestTransformer<T, S>( Stream<S> predicate(T value)): StreamTransformer<T, S> - removed:
function flatMapTransformer<T, S>(Stream<S> predicate(T value)): StreamTransformer<T, S> - removed:
function groupByTransformer<T, S>( S keySelector(T value), {int compareKeys(S keyA, S keyB) = …}): StreamTransformer<T, GroupByMap<S, T>> - removed:
function ignoreElementsTransformer<T>(): StreamTransformer<T, T> - removed:
function intervalTransformer<T>(Duration duration): StreamTransformer<T, T> - removed:
function materializeTransformer<T>(): StreamTransformer<T, Notification<T>> - removed:
function maxTransformer<T>([int compare(T a, T b)]): StreamTransformer<T, T> - removed:
function minTransformer<T>([int compare(T a, T b)]): StreamTransformer<T, T> - removed:
function ofTypeTransformer<T, S>(TypeToken<S> typeToken): StreamTransformer<T, S> - removed:
function onErrorResumeNextTransformer<T>( Stream<T> recoveryStream): StreamTransformer<T, T> - removed:
function repeatTransformer<T>(int repeatCount): StreamTransformer<T, T> - removed:
function retryTransformer<T>(int count): StreamTransformer<T, T> - removed:
function sampleTransformer<T>(Stream<dynamic> sampleStream): StreamTransformer<T, T> - removed:
function scanTransformer<T, S>( S predicate(S accumulated, T value, int index), [S seed]): StreamTransformer<T, S> - removed:
function startWithManyTransformer<T>(List<T> startValues): StreamTransformer<T, T> - removed:
function startWithTransformer<T>(T startValue): StreamTransformer<T, T> - removed:
function switchIfEmptyTransformer<T>(Stream<T> fallbackStream): StreamTransformer<T, T> - removed:
function takeUntilTransformer<T, S>(Stream<S> otherStream): StreamTransformer<T, T> - removed:
function throttleTransformer<T>(Duration duration): StreamTransformer<T, T> - removed:
function timeIntervalTransformer<T, S extends TimeInterval<T>>(): StreamTransformer<T, S> - removed:
function timestampTransformer<T>(): StreamTransformer<T, Timestamped<T>> - removed:
function windowWithCountTransformer<T, S extends Stream<T>>( int count, [int skip]): StreamTransformer<T, S> - removed:
function withLatestFromTransformer<T, S, R>( Stream<S> latestFromStream, R fn(T t, S s)): StreamTransformer<T, R> - removed:
method RetryError.toString(): String - added:
class BufferWithCountStreamTransformer<T, S extends List<T>> implements StreamTransformer<T, S> - added:
class CallStreamTransformer<T> implements StreamTransformer<T, T> - added:
class ConcatMapStreamTransformer<T, S> implements StreamTransformer<T, S> - added:
class DebounceStreamTransformer<T> implements StreamTransformer<T, T> - added:
class DefaultIfEmptyStreamTransformer<T> implements StreamTransformer<T, T> - added:
class DematerializeStreamTransformer<T> implements StreamTransformer<Notification<T>, T> - added:
class FlatMapLatestStreamTransformer<T, S> implements StreamTransformer<T, S> - added:
class FlatMapStreamTransformer<T, S> implements StreamTransformer<T, S> - added:
class GroupByStreamTransformer<T, S> implements StreamTransformer<T, GroupByMap<S, T>> - added:
class IgnoreElementsStreamTransformer<T> implements StreamTransformer<T, T> - added:
class IntervalStreamTransformer<T> implements StreamTransformer<T, T> - added:
class MaterializeStreamTransformer<T> implements StreamTransformer<T, Notification<T>> - added:
class MaxStreamTransformer<T> implements StreamTransformer<T, T> - added:
class MinStreamTransformer<T> implements StreamTransformer<T, T> - added:
class OfTypeStreamTransformer<T, S> implements StreamTransformer<T, S> - added:
class OnErrorResumeNextStreamTransformer<T> implements StreamTransformer<T, T> - added:
class RepeatStreamTransformer<T> implements StreamTransformer<T, T> - added:
class SampleStreamTransformer<T> implements StreamTransformer<T, T> - added:
class ScanStreamTransformer<T, S> implements StreamTransformer<T, S> - added:
class SkipUntilStreamTransformer<T, S> implements StreamTransformer<T, T> - added:
class StartWithManyStreamTransformer<T> implements StreamTransformer<T, T> - added:
class StartWithStreamTransformer<T> implements StreamTransformer<T, T> - added:
class SwitchIfEmptyStreamTransformer<T> implements StreamTransformer<T, T> - added:
class TakeUntilStreamTransformer<T, S> implements StreamTransformer<T, T> - added:
class ThrottleStreamTransformer<T> implements StreamTransformer<T, T> - added:
class TimeIntervalStreamTransformer<T, S extends TimeInterval<T>> implements StreamTransformer<T, S> - added:
class TimestampStreamTransformer<T> implements StreamTransformer<T, Timestamped<T>> - added:
class WindowWithCountStreamTransformer<T, S extends Stream<T>> implements StreamTransformer<T, S> - added:
class WithLatestFromStreamTransformer<T, S, R> implements StreamTransformer<T, R> - added:
ctor BufferWithCountStreamTransformer(this.count, [this.skip]) - added:
ctor CallStreamTransformer( {void onCancel(), void onData(T event), void onDone(), void onEach(Notification<T> notification), Function onError, void onListen(), void onPause(Future<dynamic> resumeSignal), void onResume()}) - added:
ctor ConcatMapStreamTransformer(Stream<S> predicate(T value)) - added:
ctor DebounceStreamTransformer(Duration duration) - added:
ctor DefaultIfEmptyStreamTransformer(T defaultValue) - added:
ctor DematerializeStreamTransformer() - added:
ctor FlatMapLatestStreamTransformer(Stream<S> predicate(T value)) - added:
ctor FlatMapStreamTransformer(Stream<S> predicate(T value)) - added:
ctor GroupByStreamTransformer(S keySelector(T value), {int compareKeys(S keyA, S keyB)}) - added:
ctor IgnoreElementsStreamTransformer() - added:
ctor IntervalStreamTransformer(Duration duration) - added:
ctor MaterializeStreamTransformer() - added:
ctor MaxStreamTransformer([this.compare]) - added:
ctor MinStreamTransformer([this.compare]) - added:
ctor OfTypeStreamTransformer(TypeToken<S> typeToken) - added:
ctor OnErrorResumeNextStreamTransformer(Stream<T> recoveryStream) - added:
ctor RepeatStreamTransformer(int repeatCount) - added:
ctor SampleStreamTransformer(Stream<dynamic> sampleStream) - added:
ctor ScanStreamTransformer(this.predicate, [this.seed]) - added:
ctor SkipUntilStreamTransformer(Stream<S> otherStream) - added:
ctor StartWithManyStreamTransformer(List<T> startValues) - added:
ctor StartWithStreamTransformer(T startValue) - added:
ctor SwitchIfEmptyStreamTransformer(Stream<T> fallbackStream) - added:
ctor TakeUntilStreamTransformer(Stream<S> otherStream) - added:
ctor ThrottleStreamTransformer(Duration duration) - added:
ctor TimeIntervalStreamTransformer() - added:
ctor TimestampStreamTransformer() - added:
ctor WindowWithCountStreamTransformer(int count, [int skip]) - added:
ctor WithLatestFromStreamTransformer(Stream<S> latestFromStream, R fn(T t, S s)) - added:
field BufferWithCountStreamTransformer.count: final int - added:
field BufferWithCountStreamTransformer.skip: final int - added:
field CallStreamTransformer.transformer: final StreamTransformer<T, T> - added:
field ConcatMapStreamTransformer.transformer: final StreamTransformer<T, S> - added:
field DebounceStreamTransformer.transformer: final StreamTransformer<T, T> - added:
field DefaultIfEmptyStreamTransformer.transformer: final StreamTransformer<T, T> - added:
field DematerializeStreamTransformer.transformer: final StreamTransformer<Notification<T>, T> - added:
field FlatMapLatestStreamTransformer.transformer: final StreamTransformer<T, S> - added:
field FlatMapStreamTransformer.transformer: final StreamTransformer<T, S> - added:
field GroupByStreamTransformer.transformer: final StreamTransformer<T, GroupByMap<S, T>> - added:
field IgnoreElementsStreamTransformer.transformer: final StreamTransformer<T, T> - added:
field IntervalStreamTransformer.transformer: final StreamTransformer<T, T> - added:
field MaterializeStreamTransformer.transformer: final StreamTransformer<T, Notification<T>> - added:
field MaxStreamTransformer.compare: final _MaxStreamTransformerCompare<T> - added:
field MinStreamTransformer.compare: final _MinStreamTransformerCompare<T> - added:
field OfTypeStreamTransformer.transformer: final StreamTransformer<T, S> - added:
field OnErrorResumeNextStreamTransformer.transformer: final StreamTransformer<T, T> - added:
field RepeatStreamTransformer.transformer: final StreamTransformer<T, T> - added:
field SampleStreamTransformer.transformer: final StreamTransformer<T, T> - added:
field ScanStreamTransformer.predicate: final _ScanStreamTransformerPredicate<T, S> - added:
field ScanStreamTransformer.seed: final S - added:
field SkipUntilStreamTransformer.transformer: final StreamTransformer<T, T> - added:
field StartWithManyStreamTransformer.transformer: final StreamTransformer<T, T> - added:
field StartWithStreamTransformer.transformer: final StreamTransformer<T, T> - added:
field SwitchIfEmptyStreamTransformer.transformer: final StreamTransformer<T, T> - added:
field TakeUntilStreamTransformer.transformer: final StreamTransformer<T, T> - added:
field ThrottleStreamTransformer.transformer: final StreamTransformer<T, T> - added:
field TimeIntervalStreamTransformer.transformer: final StreamTransformer<T, S> - added:
field TimestampStreamTransformer.transformer: final StreamTransformer<T, Timestamped<T>> - added:
field WindowWithCountStreamTransformer.transformer: final StreamTransformer<T, S> - added:
field WithLatestFromStreamTransformer.transformer: final StreamTransformer<T, R> - added:
method BufferWithCountStreamTransformer.bind(Stream<T> stream): Stream<S> - added:
method CallStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method ConcatMapStreamTransformer.bind(Stream<T> stream): Stream<S> - added:
method DebounceStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method DefaultIfEmptyStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method DematerializeStreamTransformer.bind(Stream<Notification<T>> stream): Stream<T> - added:
method FlatMapLatestStreamTransformer.bind(Stream<T> stream): Stream<S> - added:
method FlatMapStreamTransformer.bind(Stream<T> stream): Stream<S> - added:
method GroupByStreamTransformer.bind(Stream<T> stream): Stream<GroupByMap<S, T>> - added:
method IgnoreElementsStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method IntervalStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method MaterializeStreamTransformer.bind(Stream<T> stream): Stream<Notification<T>> - added:
method MaxStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method MinStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method OfTypeStreamTransformer.bind(Stream<T> stream): Stream<S> - added:
method OnErrorResumeNextStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method RepeatStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method SampleStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method ScanStreamTransformer.bind(Stream<T> stream): Stream<S> - added:
method SkipUntilStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method StartWithManyStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method StartWithStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method SwitchIfEmptyStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method TakeUntilStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method ThrottleStreamTransformer.bind(Stream<T> stream): Stream<T> - added:
method TimeIntervalStreamTransformer.bind(Stream<T> stream): Stream<S> - added:
method TimestampStreamTransformer.bind(Stream<T> stream): Stream<Timestamped<T>> - added:
method WindowWithCountStreamTransformer.bind(Stream<T> stream): Stream<S> - added:
method WithLatestFromStreamTransformer.bind(Stream<T> stream): Stream<R>