Module Future.Pipe

module Reader : sig ... end
val read : 'a Reader.t -> [ `Eof | `Ok of 'a ] Deferred.t
val junk : 'a Reader.t -> unit Deferred.t

Discard one item from the pipe. Do nothing if pipe is already fully consumed. Difference from Async: This function is not defined.

val peek_deferred : 'a Reader.t -> [ `Eof | `Ok of 'a ] Deferred.t

Like read but doesn't consume the item. Difference from Async: This function is not defined. We don't call this function peek because that is already another function in Async, which has different semantics.

val map : 'a Reader.t -> f:('a -> 'b) -> 'b Reader.t
val fold : 'a Reader.t -> init:'accum -> f:('accum -> 'a -> 'accum Deferred.t) -> 'accum Deferred.t
val iter : 'a Reader.t -> f:('a -> unit Deferred.t) -> unit Deferred.t