Class QueueSink<T>