enqueue method

void enqueue(FutureOr<void> job())

Schedules a job.

Errors inside a job are logged and swallowed, so one bad attachment can neither take down the test process nor abort drain for its peers.

Implementation

void enqueue(FutureOr<void> Function() job) {
  _queue.add(job);
  _pump();
}