Refactored create stream_pool