Pi (u.22e876fa88e25e34740ddad6ab20cbaf.eio.1.3.doc.eio.Eio.Flow.Pi)

Sourcemodule type SOURCE = sig ... end

Sourcemodule type SINK = sig ... end

Sourcemodule type SHUTDOWN = sig ... end

val source : 
  (module SOURCE with type t = 't) ->
  ('t, source_ty) Resource.handler

Sourceval sink : (module SINK with type t = 't) -> ('t, sink_ty) Resource.handler

val shutdown : 
  (module SHUTDOWN with type t = 't) ->
  ('t, shutdown_ty) Resource.handler

Sourcemodule type TWO_WAY = sig ... end

val two_way : 
  (module TWO_WAY with type t = 't) ->
  ('t, two_way_ty) Resource.handler

Sourcetype Resource.pi +=

| Source : ('t, (module SOURCE with type t = 't), [> source_ty ]) Resource.pi
| Sink : ('t, (module SINK with type t = 't), [> sink_ty ]) Resource.pi
| Shutdown : ('t, (module SHUTDOWN with type t = 't), [> shutdown_ty ]) Resource.pi

val simple_copy : 
  single_write:('t -> Cstruct.t list -> int) ->
  't ->
  src:_ source ->
  unit

simple_copy ~single_write implements SINK's copy API using single_write.