1 write to _inputQueue
System.ServiceModel.Primitives (1)
System\ServiceModel\Channels\InputQueueChannel.cs (1)
18
_inputQueue
= TraceUtility.CreateInputQueue<TDisposable>();
16 references to _inputQueue
System.ServiceModel.Primitives (16)
System\ServiceModel\Channels\InputQueueChannel.cs (16)
21
public int InternalPendingItems =>
_inputQueue
.PendingCount;
42
_inputQueue
.EnqueueAndDispatch(item, dequeuedCallback, canDispatchOnThisThread);
48
_inputQueue
.EnqueueAndDispatch(exception, dequeuedCallback, canDispatchOnThisThread);
56
_inputQueue
.EnqueueAndDispatch(item, dequeuedCallback);
62
return
_inputQueue
.EnqueueWithoutDispatch(exception, dequeuedCallback);
70
return
_inputQueue
.EnqueueWithoutDispatch(item, dequeuedCallback);
76
_inputQueue
.Dispatch();
81
_inputQueue
.Shutdown();
87
_inputQueue
.Shutdown(() => GetPendingException());
97
(bool dequeued, TDisposable item) = await
_inputQueue
.TryDequeueAsync(timeout);
111
bool dequeued = await
_inputQueue
.WaitForItemAsync(timeout);
122
_inputQueue
.Shutdown(() => GetPendingException());
127
_inputQueue
.Close();
132
_inputQueue
.Close();
137
_inputQueue
.Close();
143
_inputQueue
.Close();