Repeater<T> constructor

Repeater<T>({
  1. required Stream<T> onListenEmitFrom(),
  2. Future onCancel()?,
  3. bool isSync = false,
})

Implementation

Repeater({
  required Stream<T> Function() onListenEmitFrom,
  Future<dynamic> Function()? onCancel,
  bool isSync = false,
})  : _onListenEmitFrom = onListenEmitFrom,
      _onCancel = onCancel,
      _isBroadcast = false,
      _isSync = isSync;