kill<O2> method

Conveyor<F, O2> kill<O2>()

Implementation

Conveyor<F, O2> kill<O2>() =>
    interpret((h, t) => t.kill<O2>(),
        (req, recv) => recv(left(Kill)).drain<O2>().onHalt((e) => e == Kill ? halt(End) : halt(e)),
        halt);