Upgrading rxdart 0.18 to 0.19
Breaking0.18.1 → 0.19.0Breaking1New3Fixed1
BreakingUpgrade verdict
1 breaking change.
In plain terms
- If you wrote a custom onCancel callback for a Subject, it can no longer return a Future.
Must act 1 item needs code or config changes
What you must change
Breaking1
Subjects' onCancel function now returns void instead of Future to comply with the StreamController signature.
onCancelStreamControllerAPI changes
Generated by DepDelta from published Dart source. Not mixed with prose notes.
- changed:
class BehaviorSubject<T> extends Subject<T> → class BehaviorSubject<T> extends Subject<T> implements ValueObservable<T> - changed:
class ReplaySubject<T> extends Subject<T> → class ReplaySubject<T> extends Subject<T> implements ReplayObservable<T> - changed:
ctor BehaviorSubject({ T seedValue, void onListen(), Future<dynamic> onCancel(), bool sync = …, }) → ctor BehaviorSubject({ T seedValue, void onListen(), void onCancel(), bool sync = …, }) - changed:
ctor PublishSubject( {void onListen(), Future<dynamic> onCancel(), bool sync = …}) → ctor PublishSubject({void onListen(), void onCancel(), bool sync = …}) - changed:
ctor ReplaySubject({ int maxSize, void onListen(), Future<dynamic> onCancel(), bool sync = …, }) → ctor ReplaySubject({ int maxSize, void onListen(), void onCancel(), bool sync = …, }) - added:
class ConnectableObservable<T>: abstract extends Observable<T> - added:
class ConnectableObservableStreamSubscription<T> extends StreamSubscription<T> - added:
class PublishConnectableObservable<T> extends ConnectableObservable<T> - added:
class ReplayConnectableObservable<T> extends ConnectableObservable<T> implements ReplayObservable<T> - added:
class ReplayObservable<T>: abstract implements Observable<T> - added:
class ValueConnectableObservable<T> extends ConnectableObservable<T> implements ValueObservable<T> - added:
class ValueObservable<T>: abstract implements Observable<T> - added:
ctor ConnectableObservable(Stream<T> stream) - added:
ctor ConnectableObservableStreamSubscription(this._source, this._subject) - added:
ctor PublishConnectableObservable(Stream<T> source) - added:
ctor ReplayConnectableObservable(Stream<T> stream, {int maxSize}) - added:
ctor ValueConnectableObservable(Stream<T> source, {T seedValue}) - added:
get BehaviorSubject.stream: ValueObservable<T> - added:
get ConnectableObservableStreamSubscription.isPaused: bool - added:
get ReplayConnectableObservable.values: List<T> - added:
get ReplayObservable.values: List<T> - added:
get ValueConnectableObservable.value: T - added:
get ValueObservable.value: T - added:
method ConnectableObservable.autoConnect({ void Function(StreamSubscription<T> subscription) connection, }): Observable<T> - added:
method ConnectableObservable.connect(): StreamSubscription<T> - added:
method ConnectableObservable.refCount(): Observable<T> - added:
method ConnectableObservableStreamSubscription.asFuture<E>([E futureValue]): Future<E> - added:
method ConnectableObservableStreamSubscription.cancel(): Future<dynamic> - added:
method ConnectableObservableStreamSubscription.onData(void Function(T data) handleData): void - added:
method ConnectableObservableStreamSubscription.onDone(void Function() handleDone): void - added:
method ConnectableObservableStreamSubscription.onError(Function handleError): void - added:
method ConnectableObservableStreamSubscription.pause([Future<dynamic> resumeSignal]): void - added:
method ConnectableObservableStreamSubscription.resume(): void - added:
method Observable.publish(): ConnectableObservable<T> - added:
method Observable.publishReplay({int maxSize}): ReplayConnectableObservable<T> - added:
method Observable.publishValue({T seedValue}): ValueConnectableObservable<T> - added:
method Observable.share(): Observable<T> - added:
method Observable.shareReplay({int maxSize}): ReplayObservable<T> - added:
method Observable.shareValue({T seedValue}): ValueObservable<T> - added:
method PublishConnectableObservable.autoConnect({ void Function(StreamSubscription<T> subscription) connection, }): Observable<T> - added:
method PublishConnectableObservable.connect(): StreamSubscription<T> - added:
method PublishConnectableObservable.refCount(): Observable<T> - added:
method ReplayConnectableObservable.autoConnect({ void Function(StreamSubscription<T> subscription) connection, }): ReplayObservable<T> - added:
method ReplayConnectableObservable.connect(): StreamSubscription<T> - added:
method ReplayConnectableObservable.refCount(): ReplayObservable<T> - added:
method ValueConnectableObservable.autoConnect({ void Function(StreamSubscription<T> subscription) connection, }): ValueObservable<T> - added:
method ValueConnectableObservable.connect(): StreamSubscription<T> - added:
method ValueConnectableObservable.refCount(): ValueObservable<T> - added:
set BehaviorSubject.value(T newValue)
- changed:
class BehaviorSubject<T> extends Subject<T> → class BehaviorSubject<T> extends Subject<T> implements ValueObservable<T> - changed:
class ReplaySubject<T> extends Subject<T> → class ReplaySubject<T> extends Subject<T> implements ReplayObservable<T> - changed:
ctor BehaviorSubject({ T seedValue, void onListen(), Future<dynamic> onCancel(), bool sync = …, }) → ctor BehaviorSubject({ T seedValue, void onListen(), void onCancel(), bool sync = …, }) - changed:
ctor PublishSubject( {void onListen(), Future<dynamic> onCancel(), bool sync = …}) → ctor PublishSubject({void onListen(), void onCancel(), bool sync = …}) - changed:
ctor ReplaySubject({ int maxSize, void onListen(), Future<dynamic> onCancel(), bool sync = …, }) → ctor ReplaySubject({ int maxSize, void onListen(), void onCancel(), bool sync = …, }) - added:
get BehaviorSubject.stream: ValueObservable<T> - added:
set BehaviorSubject.value(T newValue)