Function stream_queue 

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

Create a new stream queue for incoming messages.