Static Public Member Functions
static Channel< T >	CreateUnbounded< T > ()

static Channel< T >	CreateUnbounded< T > (UnboundedChannelOptions options)

static Channel< T >	CreateBounded< T > (int capacity)

static Channel< T >	CreateBounded< T > (BoundedChannelOptions options)

static Channel< T >	CreateBounded< T > (BoundedChannelOptions options, Action< T >? itemDropped)

static implicit	operator ChannelReader< TRead > (Channel< TWrite, TRead > channel)

static implicit	operator ChannelWriter< TWrite > (Channel< TWrite, TRead > channel)

Package Functions
	BoundedChannel (int bufferedCapacity, BoundedChannelFullMode mode, bool runContinuationsAsynchronously, Action< T > itemDropped)

Properties
object	SyncObj `[get]`

int	ItemsCountForDebugger `[get]`

bool	ChannelIsClosedForDebugger `[get]`

ChannelReader< TRead >	Reader `[get, protected set]`

ChannelWriter< TWrite >	Writer `[get, protected set]`

Private Member Functions
IEnumerator< T > IDebugEnumerable< T >.	GetEnumerator ()

Private Attributes
readonly BoundedChannelFullMode	_mode

readonly Action< T >	_itemDropped

readonly TaskCompletionSource	_completion

readonly int	_bufferedCapacity

readonly Deque< T >	_items = new Deque<T>()

readonly Deque< AsyncOperation< T > >	_blockedReaders = new Deque<AsyncOperation<T>>()

readonly Deque< VoidAsyncOperationWithData< T > >	_blockedWriters = new Deque<VoidAsyncOperationWithData<T>>()

AsyncOperation< bool >	_waitingReadersTail

AsyncOperation< bool >	_waitingWritersTail

readonly bool	_runContinuationsAsynchronously

Exception	_doneWriting

Detailed Description

Definition at line 10 of file BoundedChannel.cs.

The documentation for this class was generated from the following file:

Classes