LxWorker<T> constructor

LxWorker<T>(
  1. LxReactive<T> source,
  2. void callback(
    1. T value
    ), {
  3. dynamic onError(
    1. Object error,
    2. StackTrace stackTrace
    )?,
  4. dynamic onProcessingError(
    1. Object error,
    2. StackTrace stackTrace
    )?,
  5. bool? enableMonitoring,
  6. String? name,
})

Creates a new watcher instance.

Implementation

LxWorker(
  this.source,
  this.callback, {
  Function(Object error, StackTrace stackTrace)? onError,
  Function(Object error, StackTrace stackTrace)? onProcessingError,
  bool? enableMonitoring,
  String? name,
})  : _onError = onError,
      _onProcessingError = onProcessingError,
      _enableMonitoring = enableMonitoring,
      super(const LxWorkerStat(), name: name) {
  _init();
}