Bonsai_extra_pipe (bonsai.bonsai.extra.pipe.Bonsai_extra

module Bonsai := Bonsai.Cont

module Effect := Bonsai.Effect

val pipe : 
  ?sexp_of:('a -> Core.Sexp.t) ->
  Bonsai.graph @ local ->
  ('a -> unit Effect.t) Bonsai.t * 'a Effect.t Bonsai.t

pipe constructs a pipe of a and returns a pair containing an injection function that enqueues items and an Effect that dequeues them.