removed message queue, added stream_select functionality