class typeType of sources for bounded push-streams.['a]
bounded_push =object
..end
method size : int
method resize : int -> unit
It raises Invalid_argument
if size < 0
.
method push : 'a -> unit Lwt.t
Lwt_stream.bounded_push.push
, it raises Lwt_stream.Full
.method close : unit
Lwt_stream.bounded_push.push
will fail with Lwt_stream.Closed
.method count : int
method blocked : bool
Lwt_stream.bounded_push.push
?method closed : bool
method set_reference : 'b. 'b -> unit