Rx<T> constructor
Rx<T> ([
- T? value
Implementation
Rx([T? value]) {
_value = value;
_controller = StreamController<T>.broadcast();
_stream = FlowStream<T>(_flowStreamFunction);
}