<PackageReference Include="System.ServiceModel.Primitives" Version="8.0.0" />

System.ServiceModel.Channels.InputQueueChannel<TDisposable>

abstract class InputQueueChannel<TDisposable> : ChannelBase where TDisposable : IDisposable
public int InternalPendingItems { get; }

public int PendingItems { get; }

protected InputQueueChannel(ChannelManagerBase channelManager)

protected Task<ValueTuple<bool, TDisposable>> DequeueAsync(TimeSpan timeout)

public void Dispatch()

public void EnqueueAndDispatch(TDisposable item)

public void EnqueueAndDispatch(TDisposable item, Action dequeuedCallback, bool canDispatchOnThisThread)

public void EnqueueAndDispatch(Exception exception, Action dequeuedCallback, bool canDispatchOnThisThread)

public void EnqueueAndDispatch(TDisposable item, Action dequeuedCallback)

public bool EnqueueWithoutDispatch(Exception exception, Action dequeuedCallback)

public bool EnqueueWithoutDispatch(TDisposable item, Action dequeuedCallback)

protected virtual void OnEnqueueItem(TDisposable item)

public void Shutdown()

protected Task<bool> WaitForItemAsync(TimeSpan timeout)