yak_runner 0.3.1+1

A Dart package that makes running functions safer and easier to test

example/README.md

Example

import 'package:yak_error_handler/yak_error_handler.dart';
import 'package:yak_runner/yak_runner.dart';

Stream<int> get stream => Stream.fromIterable([for (var i = 0; i < 10; ++i) i]);

final onError = ErrorHandler<AvowError>((_) => print('this is odd!'));
final runner = UnaryRunner<void, int>(
  (i) {
    avow(i.isEven);
    print(i);
  },
  exceptionHandler: ExceptionHandler(),
  errorHandlers: {onError},
);

void main() => stream.listen(runner);

Jump to Source