drain<O2> method

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

Implementation

Conveyor<F, O2> drain<O2>() =>
    interpret((h, t) => t.drain<O2>(),
        (req, recv) => consume(req, (ea) => recv(ea).drain()),
        halt);