Skip to content

Upgrading rxdart 0.1 to 0.2

Unknown0.1.0+6 → 0.2.0+3

UnknownUpgrade verdict

DepDelta hasn't looked for this range's notes yet, so breaking changes can't be ruled out.

  • DepDelta hasn't finished looking for the notes in this range, so it can't rule out breaking changes yet.
Unknown for releases without notes

Releases without notes may still need changes. Check their commits before upgrading.

Drops test.

Generated by DepDelta from published Dart source. Not mixed with prose notes.

  • changed: ctor Observable.fromEvent(Element element, String event) → ctor Observable.fromEvent(EventTarget eventTarget, String event)
  • added: class ReplaySubject<T> extends Subject<T>
  • added: ctor Observable.amb(List observablesOrFutures)
  • added: ctor Observable.defer(Observable<T> observableFactory ())
  • added: ctor Observable.empty([Scheduler scheduler])
  • added: ctor Observable.switchCase(String selector(), Map<String, Observable> sources, {Observable elseSource, Scheduler elseScheduler})
  • added: ctor Observable.throwError(Error error, [Scheduler scheduler])
  • added: ctor ReplaySubject({int bufferSize, int windowSize, Scheduler scheduler})
  • added: method Observable.ambSingle(Observable rightSource): Observable
  • added: method Observable.count(bool predicate(T value)): Observable<T>
  • added: method Observable.distinct({dynamic keySelector(T value), bool compare(dynamic a, dynamic b)}): Observable<T>
  • added: method Observable.distinctUntilChanged({dynamic keySelector(T value), bool compare(dynamic a, dynamic b)}): Observable<T>
  • added: method Observable.find(bool predicate(T value)): Observable<T>
  • added: method Observable.reduce(T accumulator(dynamic accumulatedValue, T currentValue, int index), [dynamic seed]): Observable<T>
  • added: method Observable.retry([int retryCount = …]): Observable<T>
  • added: method Observable.retryWhen(void onErrors(errors)): Observable<T>
  • added: method Observable.scan(T accumulator(dynamic accumulatedValue, T currentValue, int index), [dynamic seed]): Observable<T>
  • added: method Observable.select(dynamic selector(T value)): Observable
  • added: method Observable.selectMany(Observable selector(T value)): Observable
  • added: method Observable.share(Observer<T> observer): Observable<T>
  • added: method Observable.startWith(List<T> values, {Scheduler scheduler}): Observable<T>
  • added: method Observable.takeUntil(dynamic observableOrFuture): Observable<T>