A Dart extension function to convert a regular Stream into an RxDart ReplayStream.

replay_stream_extension.dart

import 'package:rxdart/streams.dart';
import 'package:rxdart/subjects.dart';

extension StreamUtils<T> on Stream<T> {
  ReplayStream<T> replay() {
    final subject = ReplaySubject<T>();
    pipe(subject);
    return subject;
  }
}