Function stream_queue 

pub(crate) fn stream_queue(
    size: usize,
    memquota: &StreamAccount,
    time_prov: &DynTimeProvider,
) -> Result<(StreamQueueSender, StreamQueueReceiver), Error>

Create a new stream queue for incoming messages (messages arriving on the stream from the Tor network).