ReactiveMixin<T> mixin

An abstraction layer for RxDart Subjects. Reactive example:

class RxCounter extends Reactive<int> {
  RxCounter() : super(0);

  void increment() => value++;
  void decrement() => value--;
}
Mixin Applications

Properties

isClosed bool
Return whether the controller has already been closed or not. Once closed, it is not allowed to change the value.
read / write
value ↔ T
Returns the latest emited value by the Reactive.
@protectedread / write
isBroadcast bool
read-only
hashCode int
The hash code for this object.
read-onlyinherited
runtimeType Type
A representation of the runtime type of the object.
read-onlyinherited

Methods

add(T value) → void
Sends a new data value.
addError(Object error, [StackTrace stackTrace]) → void
close() Future<void>
Closes the sink. The add method and use the set value must not be called after this method. Calling this method more than once is allowed, but does nothing.
listen(void onData(T), {Function onError, void onDone(), bool cancelOnError}) StreamSubscription<T>
noSuchMethod(Invocation invocation) → dynamic
Invoked when a non-existent method or property is accessed.
inherited
toString() String
A string representation of this object.
inherited

Operators

operator ==(Object other) bool
The equality operator.
inherited