WebSockets - потоковая выдача

У меня есть веб-сокет сервер, основанный на Gomoob коде. Я отсылаю сообщения этому серверу для пересылки клиентам, это файлы которые передаются кусками, скажем, по 1МБ размером. Вопрос тут вот в чем - как можно сделать так, чтобы сообщения, приходящие на сервер, помещались в один и тот же поток, передающий по принципу queue (или streaming)?

Тут не важно пропустят они тот или иной "блок", важнее принцип соединения асинхронных сообщений приходящих на сервер в один и тот же отдающий поток. Как можно реализовать data streaming на сервере, чтобы данные уходили постепенно, размеренно?