hot<T> method

Observable<T> hot<T>(
  1. String marbles, {
  2. Map<String, T> values = const {},
  3. Object error = 'Error',
})

Creates a "hot" Observable whose event start replaying immediately and where subscribers all share the same unique run.

Implementation

Observable<T> hot<T>(String marbles,
    {Map<String, T> values = const {}, Object error = 'Error'}) {
  final sequence =
      TestEventSequence.fromString(marbles, values: values, error: error);
  if (sequence.events.whereType<UnsubscribeEvent<T>>().isNotEmpty) {
    throw ArgumentError.value(marbles, 'marbles',
        'Hot observable cannot have un-subscription marker.');
  }
  final observable = HotObservable<T>(this, sequence);
  observables.add(observable);
  return observable;
}