onHalt method

Conveyor<F, O> onHalt(
  1. Conveyor<F, O> f(
    1. Object err
    )
)

Implementation

Conveyor<F, O> onHalt(Conveyor<F, O> f(Object err)) =>
    interpret((h, t) => produce(h, t.onHalt(f)),
        (req, recv) => consume(req, (ea) => recv(ea).onHalt(f)),
        (err) => Try(() => f(err)));