watchValue<T> static method

LxWorker<T> watchValue<T>(
  1. LxReactive<T> source,
  2. T targetValue,
  3. void callback(), {
  4. dynamic onProcessingError(
    1. Object error,
    2. StackTrace stackTrace
    )?,
})

Triggers callback only when source matches targetValue.

Implementation

static LxWorker<T> watchValue<T>(
  LxReactive<T> source,
  T targetValue,
  void Function() callback, {
  Function(Object error, StackTrace stackTrace)? onProcessingError,
}) {
  return LxWorker<T>(
    source,
    (value) {
      if (value == targetValue) callback();
    },
    onProcessingError: onProcessingError,
  );
}