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;
}