Rx<T> constructor

Rx<T>([
  1. T? value
])

Implementation

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