llib:dart_utils

interrupt.dart

import 'dart:io';
import 'dart:async';

StreamTransformer<T, T> interrupt<T>() {
  return StreamTransformer.fromHandlers(handleData: (data, sink) {
    stdin.readLineSync();
    sink.add(data);
  });
}