1 write to _completion
System.Threading.Channels (1)
System\Threading\Channels\UnboundedChannel.cs (1)
39_completion = new TaskCompletionSource(runContinuationsAsynchronously ? TaskCreationOptions.RunContinuationsAsynchronously : TaskCreationOptions.None);
6 references to _completion
System.Threading.Channels (6)
System\Threading\Channels\UnboundedChannel.cs (6)
60public override Task Completion => _parent._completion.Task; 132ChannelUtilities.Complete(parent._completion, parent._doneWriting); 225ChannelUtilities.Complete(parent._completion, error); 241ChannelUtilities.Complete(parent._completion, error); 354Debug.Assert(!_completion.Task.IsCompleted, "We still have data available, so shouldn't be completed."); 362if (_completion.Task.IsCompleted)