my Supplier::Preserving $supplier .= new;
my Supply $out-supply = $supplier.Supply;

my Proc::Async $proc-async .= new(</bin/false>);
$proc-async.stdout.lines.tap({ say 'forwarding ' ~ $_; $supplier.emit($_) });

start {
  my Proc $done-proc = await $proc-async.start;
  say 'process exited';
  if $done-proc.exitcode != 0 {
    say 'bad exit code';
    $supplier.emit(
      Failure.new(
	"Process exited with non-zero exit code: {$done-proc.exitcode}"
      )
    );
  }
  say 'done';
  $supplier.done;
}

say 'i have control';
say $out-supply.list.Array;