Actor-based implementation of async stream reader.