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