16 references to NotAvailable
System.Threading.Tasks.Dataflow (16)
Base\DataflowBlock.cs (5)
315
case DataflowMessageStatus.
NotAvailable
:
595
case DataflowMessageStatus.
NotAvailable
:
1152
DataflowMessageStatus status = DataflowMessageStatus.
NotAvailable
;
2115
if (!consumed) return DataflowMessageStatus.
NotAvailable
;
2619
if (!messageConsumed) return DataflowMessageStatus.
NotAvailable
;
Blocks\BatchBlock.cs (1)
382
if (!consumed) return DataflowMessageStatus.
NotAvailable
;
Blocks\BatchedJoinBlock.cs (1)
584
if (!consumed) return DataflowMessageStatus.
NotAvailable
;
Blocks\BroadcastBlock.cs (3)
192
if (!consumed) return DataflowMessageStatus.
NotAvailable
;
705
else Debug.Assert(result != DataflowMessageStatus.
NotAvailable
, "Messages from a Broadcast should never be missed.");
809
case DataflowMessageStatus.
NotAvailable
:
Blocks\BufferBlock.cs (1)
120
if (!consumed) return DataflowMessageStatus.
NotAvailable
;
Blocks\JoinBlock.cs (1)
847
if (!consumed) return DataflowMessageStatus.
NotAvailable
;
Blocks\WriteOnceBlock.cs (1)
353
if (!consumed) return DataflowMessageStatus.
NotAvailable
;
Internal\SourceCore.cs (1)
672
Debug.Assert(result != DataflowMessageStatus.
NotAvailable
, "Messages are not being offered concurrently, so nothing should be missed.");
Internal\SpscTargetCore.cs (1)
145
if (!consumed) return DataflowMessageStatus.
NotAvailable
;
Internal\TargetCore.cs (1)
212
if (!consumed) return DataflowMessageStatus.
NotAvailable
;