Accepts values of type X
and converts them to an A
or B
.
Accepts values of type X
and converts them to an A
or B
. If A
, the A
is fed to p
. If B
, the B
is emitted directly.
Stream transducer that drops left values from a stream of F[A \/ B]
values.
Stream transducer that drops right values from a stream of F[A \/ B]
values.
Lifts a Process1[B, B]
to a Process1[A, A]
using the provided lens.
Lifts a Process1[B, B]
to a Process1[A, A]
using the provided lens.
Values fed to this process are converted to type B
and fed to
p
. Any B
values emitted by p
are re-emitted as A
values by
setting each B
in to the last emitted A
. Hence, the last fed A
is kept in memory by this process.
Note that this halts whenever p
halts.
Lifts a Process1[B1, B2]
to a Process1[A1, A2]
using the provided lens family.
Lifts a Process1[B1, B2]
to a Process1[A1, A2]
using the provided lens family.
Values fed to this process are converted to type B1
and fed to
p
. Any B2
values emitted by p
are re-emitted as A2
values by
setting each B2
in to the last emitted A1
. Hence, the last fed A1
is kept in memory by this process.
Note that this halts whenever p
halts.
General purpose combinators for working with
Process1
that are not included in scalaz-stream.