Use ReadStream for server connections and consume event bus messages