36 references to IsValid
System.Threading.Tasks.Dataflow (36)
Base\DataflowBlock.cs (11)
135
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
155
Debug.Assert(messageHeader.
IsValid
, "Only valid messages may be consumed.");
164
Debug.Assert(messageHeader.
IsValid
, "Only valid messages may be consumed.");
173
Debug.Assert(messageHeader.
IsValid
, "Only valid messages may be consumed.");
621
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
666
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
683
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
1149
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
1462
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
2104
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
2611
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
Blocks\BatchBlock.cs (2)
352
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
1095
if (source != null && message.Key.
IsValid
)
Blocks\BatchedJoinBlock.cs (1)
567
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
Blocks\BroadcastBlock.cs (5)
163
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
753
if (header.
IsValid
)
1035
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
1075
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
1102
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
Blocks\BufferBlock.cs (1)
91
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
Blocks\JoinBlock.cs (1)
817
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
Blocks\WriteOnceBlock.cs (9)
127
this, taskForOutputProcessing, DataflowEtwProvider.TaskLaunchedReason.OfferingOutputMessages, _header.
IsValid
? 1 : 0);
264
if (_header.
IsValid
&& (filter == null || filter(_value!)))
338
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
378
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
399
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
412
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
425
Debug.Assert(_header.
IsValid
, "A valid header is required.");
498
private bool HasValue { get { return _header.
IsValid
; } }
500
private T? Value { get { return _header.
IsValid
? _value : default(T); } }
Internal\SourceCore.cs (4)
160
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
216
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
243
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
567
if (header.
IsValid
)
Internal\SpscTargetCore.cs (1)
134
if (!messageHeader.
IsValid
)
Internal\TargetCore.cs (1)
184
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));