Есть актор, который отвечает за работу с базой (монга с асинхронным драйвером). Find монги возвращает Iterable. Как итог, для каждого найденного документа вызывается каллбэк, который пересылает найденный документ актору, который сделал запрос на данные из базы и после этого данные уходят по websocket. Есть смысл группировать данные в лист, а потом просто пересылать лист?
Если лист слишком большой, то write buffer вебсокета отвалится.
Обсуждают сегодня