Implemented async streaming