Class type Lwt_stream.bounded_push

Type of sources for bounded push-streams.

method size : int

Size of the stream.

method resize : int -> unit

Change the size of the stream queue. Note that the new size can smaller than the current stream queue size.

It raises Invalid_argument if size < 0.

method push : 'a -> unit Lwt.t

Pushes a new element to the stream. If the stream is full then it will block until one element is consumed. If another thread is already blocked on push, it raises Full.

method close : unit

Closes the stream. Any thread currently blocked on push fails with Closed.

method count : int

Number of elements in the stream queue.

method blocked : bool

Is a thread is blocked on push ?

method closed : bool

Is the stream closed ?

method set_reference : a. 'a -> unit

Set the reference to an external source.