ZipSink<TResult> abstract class ZipSink<TResult> : IdentitySink<TResult>, IZip Documentation Code protected readonly object _gate public ICollection[] Queues { get; } protected ZipSink(int arity, IObserver<TResult> observer) public void Done(int index) public void Fail(Exception error) protected abstract TResult GetResult() public void Next(int index)