Refactored Streaming method to be uses async