Upgrading rxdart 0.2 to 0.3
Unknown0.2.0+3 → 0.3.25
UnknownUpgrade verdict
DepDelta hasn't looked for this range's notes yet, so breaking changes can't be ruled out.
In plain terms
- DepDelta hasn't finished looking for the notes in this range, so it can't rule out breaking changes yet.
Must act Unknown for releases without notes
Releases without notes may still need changes. Check their commits before upgrading.
Drops browser, js.
API changes
Generated by DepDelta from published Dart source. Not mixed with prose notes.
- removed:
class Notification<T> - removed:
class Observer<T> extends Object with _ObserverMixin<T> - removed:
class ReplaySubject<T> extends Subject<T> - removed:
class Scheduler - removed:
class Subject<T> extends Observable<T> with _ObserverMixin<T> - removed:
class TimedEvent<T> - removed:
ctor Notification.createOnCompleted() - removed:
ctor Notification.createOnError(error) - removed:
ctor Notification.createOnNext(T value) - removed:
ctor Observable.amb(List observablesOrFutures) - removed:
ctor Observable.combineLatest(List<Observable> observables, [Function resultSelector]) - removed:
ctor Observable.defer(Observable<T> observableFactory ()) - removed:
ctor Observable.empty([Scheduler scheduler]) - removed:
ctor Observable.forkJoin(List observablesOrFutures, [Function resultSelector]) - removed:
ctor Observable.from(List elements) - removed:
ctor Observable.fromEvent(EventTarget eventTarget, String event) - removed:
ctor Observable.interval(Duration period, [Scheduler scheduler]) - removed:
ctor Observable.just(T value) - removed:
ctor Observable.mergeWith(Scheduler scheduler, List<Observable> observables) - removed:
ctor Observable.of(List<T> values) - removed:
ctor Observable.range(int start, int count) - removed:
ctor Observable.repeat(T value, [int repeatCount = …, Scheduler scheduler]) - removed:
ctor Observable.switchCase(String selector(), Map<String, Observable> sources, {Observable elseSource, Scheduler elseScheduler}) - removed:
ctor Observable.throwError(Error error, [Scheduler scheduler]) - removed:
ctor Observable.timer(Duration interval) - removed:
ctor Observer.create(void onListen(T value), void onError(error), void onCompleted()) - removed:
ctor Observer.fromNotifier(handler(Notification<T> kind)) - removed:
ctor ReplaySubject({int bufferSize, int windowSize, Scheduler scheduler}) - removed:
ctor Subject() - removed:
ctor Subject.create(Observer observer, Observable observable) - removed:
ctor TimedEvent(this.interval, this.value) - removed:
field TimedEvent.interval: final int - removed:
field TimedEvent.value: final T - removed:
function bypass(Stream stream, Observable handler(Observable target)): Stream - removed:
get Notification.error: dynamic - removed:
get Notification.kind: String - removed:
get Notification.value: T - removed:
method Observable.ambSingle(Observable rightSource): Observable - removed:
method Observable.count(bool predicate(T value)): Observable<T> - removed:
method Observable.debounceWithSelector(Observable selector(dynamic value)): Observable<T> - removed:
method Observable.delay(Duration duration): Observable<T> - removed:
method Observable.delayUntil(DateTime dateTime): Observable<T> - removed:
method Observable.delayWithDurationSelector(Observable<int> delayDurationSelector(int interval)): Observable<T> - removed:
method Observable.delayWithSubscriptionDelay(Observable<int> subscriptionDelay, [Observable<int> delayDurationSelector(int interval)]): Observable<T> - removed:
method Observable.distinctUntilChanged({dynamic keySelector(T value), bool compare(dynamic a, dynamic b)}): Observable<T> - removed:
method Observable.filter(bool predicate(T value)): Observable<T> - removed:
method Observable.find(bool predicate(T value)): Observable<T> - removed:
method Observable.partition(bool predicate(T value)): List<Observable<T>> - removed:
method Observable.reduce(T accumulator(dynamic accumulatedValue, T currentValue, int index), [dynamic seed]): Observable<T> - removed:
method Observable.retryWhen(void onErrors(errors)): Observable<T> - removed:
method Observable.select(dynamic selector(T value)): Observable - removed:
method Observable.selectMany(Observable selector(T value)): Observable - removed:
method Observable.share(Observer<T> observer): Observable<T> - removed:
method Observable.subscribe(void onListen(T value), {void onError(error), void onCompleted()}): Rx.Disposable - removed:
method Observable.subscribeWith(Observer observer): Rx.Disposable - removed:
method Observable.tapWith(Observer<T> observer): Observable<T> - removed:
method Observable.toList(): Observable<List<T>> - removed:
method Observable.toStream(): Stream<T> - removed:
method Scheduler.schedule(dynamic state, void action(Scheduler scheduler, dynamic state)): Scheduler - removed:
method Scheduler.scheduleFuture(dynamic state, Duration duration, void action(Scheduler scheduler, dynamic state)): Scheduler - removed:
method Scheduler.scheduleFutureUntil(dynamic state, DateTime dateTime, void action(Scheduler scheduler, dynamic state)): Scheduler - removed:
method Scheduler.schedulePeriodic(dynamic state, Duration period, void action(dynamic state)): Scheduler - removed:
method Scheduler.scheduleRecursive(dynamic state, void action(dynamic state, Function recurse)): Scheduler - removed:
method Scheduler.scheduleRecursiveFuture(dynamic state, Duration duration, void action(dynamic state, Function recurse)): Scheduler - removed:
method Scheduler.scheduleRecursiveFutureUntil(dynamic state, DateTime dateTime, void action(dynamic state, Function recurse)): Scheduler - removed:
static field Notification.COMPLETED: const String - removed:
static field Notification.ERROR: const String - removed:
static field Notification.NEXT: const String - removed:
static get Scheduler.asDefault: Scheduler - removed:
static get Scheduler.currentThread: Scheduler - removed:
static get Scheduler.immediate: Scheduler - changed:
class Observable<T> → class Observable<T>: abstract extends Stream<T> - changed:
ctor Observable.fromFuture(Future future) → ctor Observable.fromFuture(Future<T> future) - changed:
ctor Observable.fromStream(Stream<T> stream) → ctor Observable.fromStream(Stream stream) - changed:
ctor Observable.merge(List<Observable> observables) → ctor Observable.merge(Iterable<Stream<T>> streams, {asBroadcastStream = …}) - changed:
method Observable.debounce(Duration duration, [Scheduler scheduler]): Observable<T> → method Observable.debounce(Duration duration): Observable<T> - changed:
method Observable.distinct({dynamic keySelector(T value), bool compare(dynamic a, dynamic b)}): Observable<T> → method Observable.distinct([bool equals(T previous, T next)]): Observable<T> - changed:
method Observable.flatMap(Observable selector(T value)): Observable → method Observable.flatMap(Stream predicate(T value)): Observable - changed:
method Observable.flatMapLatest(Observable selector(T value)): Observable → method Observable.flatMapLatest(Stream predicate(T value)): Observable - changed:
method Observable.map(dynamic selector(T value)): Observable → method Observable.map( convert(T event)): Observable - changed:
method Observable.pluck(List<String> path): Observable → method Observable.pluck(List<dynamic> sequence, {bool throwOnNull = …}): Observable - changed:
method Observable.retry([int retryCount = …]): Observable<T> → method Observable.retry([int count]): Observable<T> - changed:
method Observable.scan(T accumulator(dynamic accumulatedValue, T currentValue, int index), [dynamic seed]): Observable<T> → method Observable.scan(dynamic predicate( dynamic accumulated, T value, int index), [dynamic seed]): Observable - changed:
method Observable.startWith(List<T> values, {Scheduler scheduler}): Observable<T> → method Observable.startWith(List<T> startValues): Observable<T> - changed:
method Observable.take(int amount, [Scheduler scheduler]): Observable<T> → method Observable.take(int count): Observable<T> - changed:
method Observable.takeUntil(dynamic observableOrFuture): Observable<T> → method Observable.takeUntil(Stream otherStream): Observable<T> - changed:
method Observable.tap(void onListen(T value), {void onError(error), void onCompleted()}): Observable<T> → method Observable.tap(void action(T value)): Observable<T> - changed:
method Observable.throttle(Duration duration, [Scheduler scheduler]): Observable<T> → method Observable.throttle(Duration duration): Observable<T> - changed:
method Observable.timeInterval([Scheduler scheduler]): Observable<TimedEvent<T>> → method Observable.timeInterval(): Observable<TimeInterval<T>> - added:
class TimeInterval<T> - added:
ctor Observable() - added:
ctor Observable.combineLatestMap(Map<String, Stream<T>> streamMap, {asBroadcastStream = …}) - added:
ctor Observable.eventTransformed(Stream source, EventSink mapSink(EventSink<T> sink)) - added:
ctor Observable.fromIterable(Iterable<T> data) - added:
ctor Observable.periodic(Duration period, [T computation(int computationCount)]) - added:
ctor Observable.tween(double startValue, double changeInTime, Duration duration, {int intervalMs = …, Ease ease = …, asBroadcastStream = …}) - added:
ctor TimeInterval(this.value, this.interval) - added:
enum Ease - added:
field TimeInterval.interval: final int - added:
field TimeInterval.value: final T - added:
function observable(Stream<dynamic > stream): Observable - added:
member Ease.IN - added:
member Ease.IN_OUT - added:
member Ease.LINEAR - added:
member Ease.OUT - added:
method Observable.asBroadcastStream({ void onListen(StreamSubscription<T> subscription), void onCancel(StreamSubscription<T> subscription) }): Observable<T> - added:
method Observable.asyncExpand(Stream convert(T value)): Observable - added:
method Observable.asyncMap(dynamic convert(T value)): Observable - added:
method Observable.combineLatest(Iterable<Stream> streams, Function predicate, {asBroadcastStream = …}): Observable . - added:
method Observable.expand(Iterable convert(T value)): Observable - added:
method Observable.handleError(Function onError, { bool test(error) }): Observable<T> - added:
method Observable.interval(Duration duration): Observable<T> - added:
method Observable.max([int compare(T a, T b)]): Observable<T> - added:
method Observable.min([int compare(T a, T b)]): Observable<T> - added:
method Observable.repeat(int repeatCount): Observable<T> - added:
method Observable.replay({int bufferSize = …, bool completeWhenBufferExhausted = …}): Observable<T> - added:
method Observable.reverse(): Observable<T> - added:
method Observable.sample(Stream sampleStream): Observable<T> - added:
method Observable.skip(int count): Observable<T> - added:
method Observable.skipWhile(bool test(T element)): Observable<T> - added:
method Observable.takeWhile(bool test(T element)): Observable<T> - added:
method Observable.timeout(Duration timeLimit, {void onTimeout(EventSink<T> sink)}): Observable<T> - added:
method Observable.where(bool test(T event)): Observable<T> - added:
method Observable.zip(Iterable<Stream> streams, Function predicate, {asBroadcastStream = …}): Observable .