stream-like API for websockets