19 references to DecliningPermanently
System.Threading.Tasks.Dataflow (19)
Base\DataflowBlock.cs (8)
307
case DataflowMessageStatus.
DecliningPermanently
:
591
case DataflowMessageStatus.
DecliningPermanently
:
1157
if (Volatile.Read(ref _cleanupReserved)) return DataflowMessageStatus.
DecliningPermanently
;
1162
if (_cleanupReserved) return DataflowMessageStatus.
DecliningPermanently
;
1179
status = DataflowMessageStatus.
DecliningPermanently
;
1191
else if (status == DataflowMessageStatus.
DecliningPermanently
) // should only be the case if an error occurred
1467
return DataflowMessageStatus.
DecliningPermanently
;
2108
if (_completed.Value != null || base.Task.IsCompleted) return DataflowMessageStatus.
DecliningPermanently
;
Blocks\BatchBlock.cs (1)
361
return DataflowMessageStatus.
DecliningPermanently
;
Blocks\BatchedJoinBlock.cs (1)
575
return DataflowMessageStatus.
DecliningPermanently
;
Blocks\BroadcastBlock.cs (3)
172
return DataflowMessageStatus.
DecliningPermanently
;
701
else if (result == DataflowMessageStatus.
DecliningPermanently
)
804
case DataflowMessageStatus.
DecliningPermanently
:
Blocks\BufferBlock.cs (1)
100
return DataflowMessageStatus.
DecliningPermanently
;
Blocks\JoinBlock.cs (1)
826
return DataflowMessageStatus.
DecliningPermanently
;
Blocks\WriteOnceBlock.cs (1)
345
if (_decliningPermanently) return DataflowMessageStatus.
DecliningPermanently
;
Internal\SourceCore.cs (1)
683
else if (result == DataflowMessageStatus.
DecliningPermanently
)
Internal\SpscTargetCore.cs (1)
130
return DataflowMessageStatus.
DecliningPermanently
;
Internal\TargetCore.cs (1)
193
return DataflowMessageStatus.
DecliningPermanently
;