Type of sources for bounded push-streams.
Change the size of the stream queue. Note that the new size can smaller than the current stream queue size.
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
Closes the stream. Any thread currently blocked on
Lwt_stream.bounded_push.push fails with