nb_blocks:int ->
blank:(unit -> 'a) ->
object
  val buffer : 'a array
  val mutable read : int
  val mutable state : [ `Crashed | `Idle | `Running of Thread.t | `Tired ]
  val wait_c : Condition.t
  val wait_m : Mutex.t
  val mutable write : int
  method virtual close : unit
  method private get_block : 'a
  method virtual id : string
  method output_get_ready : unit
  method virtual pull_block : 'a -> unit
  method private sleep : unit
  method sourcering_stop : unit
  method private writer : unit
end