19 references to DecliningPermanently
System.Threading.Tasks.Dataflow (19)
Base\DataflowBlock.cs (8)
331
case DataflowMessageStatus.
DecliningPermanently
:
615
case DataflowMessageStatus.
DecliningPermanently
:
1190
if (Volatile.Read(ref _cleanupReserved)) return DataflowMessageStatus.
DecliningPermanently
;
1195
if (_cleanupReserved) return DataflowMessageStatus.
DecliningPermanently
;
1212
status = DataflowMessageStatus.
DecliningPermanently
;
1224
else if (status == DataflowMessageStatus.
DecliningPermanently
) // should only be the case if an error occurred
1500
return DataflowMessageStatus.
DecliningPermanently
;
2189
if (_completed.Value != null || base.Task.IsCompleted) return DataflowMessageStatus.
DecliningPermanently
;
Blocks\BatchBlock.cs (1)
364
return DataflowMessageStatus.
DecliningPermanently
;
Blocks\BatchedJoinBlock.cs (1)
581
return DataflowMessageStatus.
DecliningPermanently
;
Blocks\BroadcastBlock.cs (3)
178
return DataflowMessageStatus.
DecliningPermanently
;
707
else if (result == DataflowMessageStatus.
DecliningPermanently
)
810
case DataflowMessageStatus.
DecliningPermanently
:
Blocks\BufferBlock.cs (1)
103
return DataflowMessageStatus.
DecliningPermanently
;
Blocks\JoinBlock.cs (1)
838
return DataflowMessageStatus.
DecliningPermanently
;
Blocks\WriteOnceBlock.cs (1)
357
if (_decliningPermanently) return DataflowMessageStatus.
DecliningPermanently
;
Internal\SourceCore.cs (1)
689
else if (result == DataflowMessageStatus.
DecliningPermanently
)
Internal\SpscTargetCore.cs (1)
130
return DataflowMessageStatus.
DecliningPermanently
;
Internal\TargetCore.cs (1)
193
return DataflowMessageStatus.
DecliningPermanently
;