sig
  type ('a, 'phantom) t = ('a, 'phantom) Pipe.t
  type ('a, 'phantom) pipe = ('a, 'phantom) t
  module Writer :
    sig
      type phantom = Pipe.Writer.phantom
      type 'a t = ('a, phantom) pipe
      val invariant : 'a t -> unit
      val sexp_of_t : ('a -> Sexplib.Sexp.t) -> 'a t -> Sexplib.Sexp.t
    end
  module Reader :
    sig
      type phantom = Pipe.Reader.phantom
      type 'a t = ('a, phantom) pipe
      val invariant : 'a t -> unit
      val sexp_of_t : ('a -> Sexplib.Sexp.t) -> 'a t -> Sexplib.Sexp.t
    end
  val create : unit -> 'a Reader.t * 'a Writer.t
  val init : ('a Writer.t -> unit Deferred.t) -> 'a Reader.t
  val of_list : 'a list -> 'a Reader.t
  val close : 'a Writer.t -> unit
  val close_read : 'a Reader.t -> unit
  val is_closed : ('a, 'b) pipe -> bool
  val closed : ('a, 'b) pipe -> unit Deferred.t
  module Flushed_result :
    sig
      type t = [ `Ok | `Reader_closed ]
      val sexp_of_t : t -> Sexplib.Sexp.t
    end
  val upstream_flushed : ('a, 'b) pipe -> Flushed_result.t Deferred.t
  val downstream_flushed : ('a, 'b) pipe -> Flushed_result.t Deferred.t
  module Consumer :
    sig type t = Pipe.Consumer.t val values_sent_downstream : t -> unit end
  val add_consumer :
    'a Reader.t ->
    downstream_flushed:(unit -> Flushed_result.t Deferred.t) -> Consumer.t
  val length : ('a, 'b) pipe -> int
  val is_empty : ('a, 'b) pipe -> bool
  val pushback : 'a Writer.t -> unit Deferred.t
  val write' : 'a Writer.t -> 'a Core.Std.Queue.t -> unit Deferred.t
  val write : 'a Writer.t -> 'a -> unit Deferred.t
  val write_without_pushback' : 'a Writer.t -> 'a Core.Std.Queue.t -> unit
  val write_without_pushback : 'a Writer.t -> 'a -> unit
  val write_when_ready :
    'a Writer.t ->
    f:(('a -> unit) -> 'b) -> [ `Closed | `Ok of 'b ] Deferred.t
  val read' :
    ?consumer:Consumer.t ->
    'a Reader.t -> [ `Eof | `Ok of 'a Core.Std.Queue.t ] Deferred.t
  val read :
    ?consumer:Consumer.t -> 'a Reader.t -> [ `Eof | `Ok of 'a ] Deferred.t
  val read_at_most :
    ?consumer:Consumer.t ->
    'a Reader.t ->
    num_values:int -> [ `Eof | `Ok of 'a Core.Std.Queue.t ] Deferred.t
  val read_exactly :
    ?consumer:Consumer.t ->
    'a Reader.t ->
    num_values:int ->
    [ `Eof | `Exactly of 'a Core.Std.Queue.t | `Fewer of 'a Core.Std.Queue.t ]
    Deferred.t
  val read_now' :
    ?consumer:Consumer.t ->
    'a Reader.t -> [ `Eof | `Nothing_available | `Ok of 'a Core.Std.Queue.t ]
  val read_now :
    ?consumer:Consumer.t ->
    'a Reader.t -> [ `Eof | `Nothing_available | `Ok of 'a ]
  val peek : 'a Reader.t -> 'a option
  val clear : 'a Reader.t -> unit
  val read_all : 'a Reader.t -> 'a Core.Std.Queue.t Deferred.t
  val values_available : 'a Reader.t -> [ `Eof | `Ok ] Deferred.t
  type ('a, 'b, 'c, 'accum) fold =
      ?consumer:Consumer.t ->
      'a Reader.t ->
      init:'accum -> f:('accum -> 'b -> 'c) -> 'accum Deferred.t
  val fold' : ('a, 'a Core.Std.Queue.t, 'accum Deferred.t, 'accum) fold
  val fold : ('a, 'a, 'accum, 'accum) fold
  type ('a, 'b, 'c) iter =
      ?consumer:Consumer.t ->
      ?continue_on_error:bool ->
      'a Reader.t -> f:('b -> 'c) -> unit Deferred.t
  val iter' : ('a, 'a Core.Std.Queue.t, unit Deferred.t) iter
  val iter : ('a, 'a, unit Deferred.t) iter
  val iter_without_pushback : ('a, 'a, unit) iter
  val transfer' :
    'a Reader.t ->
    'b Writer.t ->
    f:('a Core.Std.Queue.t -> 'b Core.Std.Queue.t Deferred.t) ->
    unit Deferred.t
  val transfer :
    'a Reader.t -> 'b Writer.t -> f:('a -> 'b) -> unit Deferred.t
  val transfer_id : 'a Reader.t -> 'a Writer.t -> unit Deferred.t
  val map' :
    'a Reader.t ->
    f:('a Core.Std.Queue.t -> 'b Core.Std.Queue.t Deferred.t) -> 'b Reader.t
  val map : 'a Reader.t -> f:('a -> 'b) -> 'b Reader.t
  val filter_map' :
    'a Reader.t -> f:('a -> 'b option Deferred.t) -> 'b Reader.t
  val filter_map : 'a Reader.t -> f:('a -> 'b option) -> 'b Reader.t
  val filter : 'a Reader.t -> f:('a -> bool) -> 'a Reader.t
  val interleave : 'a Reader.t list -> 'a Reader.t
  val concat : 'a Reader.t list -> 'a Reader.t
  val to_stream_deprecated : 'a Reader.t -> 'a Async_stream.t
  val of_stream_deprecated : 'a Async_stream.t -> 'a Reader.t
  val drain : 'a Reader.t -> unit Deferred.t
  val drain_and_count : 'a Reader.t -> int Deferred.t
  val to_list : 'a Reader.t -> 'a list Deferred.t
  val hash : ('a, 'b) pipe -> int
  val equal : ('a, 'b) pipe -> ('a, 'b) pipe -> bool
  val size_budget : ('a, 'b) pipe -> int
  val set_size_budget : ('a, 'b) pipe -> int -> unit
  val show_debug_messages : bool ref
  val check_invariant : bool ref
  val sexp_of_t :
    ('a -> Sexplib.Sexp.t) ->
    ('phantom -> Sexplib.Sexp.t) -> ('a, 'phantom) pipe -> Sexplib.Sexp.t
  val sexp_of_pipe :
    ('a -> Sexplib.Sexp.t) ->
    ('phantom -> Sexplib.Sexp.t) -> ('a, 'phantom) pipe -> Sexplib.Sexp.t
end