module Reader : sig ... endval read : 'a Reader.t -> [ `Eof | `Ok of 'a ] Deferred.tval junk : 'a Reader.t -> unit Deferred.tDiscard 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.tLike 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 fold :
'a Reader.t ->
init:'accum ->
f:('accum -> 'a -> 'accum Deferred.t) ->
'accum Deferred.tval iter : 'a Reader.t -> f:('a -> unit Deferred.t) -> unit Deferred.t