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
	UnboundedChannel (bool runContinuationsAsynchronously)

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 TaskCompletionSource	_completion

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

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

readonly bool	_runContinuationsAsynchronously

AsyncOperation< bool >	_waitingReadersTail

Exception	_doneWriting

Detailed Description

Definition at line 11 of file UnboundedChannel.cs.

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

Classes