streamWithCurrent property

Stream<T> get streamWithCurrent

Implementation

Stream<T> get streamWithCurrent =>
    // ignore: invalid_use_of_protected_member, invalid_use_of_visible_for_testing_member
    Rx.concatEager([Stream.value(state), stream]);