Add QueuedStreamSinkChannel which will take care of queue sends if needed