36 references to IsValid
System.Threading.Tasks.Dataflow (36)
Base\DataflowBlock.cs (11)
153
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
173
Debug.Assert(messageHeader.
IsValid
, "Only valid messages may be consumed.");
182
Debug.Assert(messageHeader.
IsValid
, "Only valid messages may be consumed.");
191
Debug.Assert(messageHeader.
IsValid
, "Only valid messages may be consumed.");
645
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
690
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
707
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
1182
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
1495
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
2183
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
2699
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
Blocks\BatchBlock.cs (2)
355
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
1098
if (source != null && message.Key.
IsValid
)
Blocks\BatchedJoinBlock.cs (1)
573
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
Blocks\BroadcastBlock.cs (5)
169
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
759
if (header.
IsValid
)
1047
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
1087
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
1114
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
Blocks\BufferBlock.cs (1)
94
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
Blocks\JoinBlock.cs (1)
829
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
Blocks\WriteOnceBlock.cs (9)
130
this, taskForOutputProcessing, DataflowEtwProvider.TaskLaunchedReason.OfferingOutputMessages, _header.
IsValid
? 1 : 0);
270
if (_header.
IsValid
&& (filter == null || filter(_value!)))
350
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
390
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
411
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
424
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
437
Debug.Assert(_header.
IsValid
, "A valid header is required.");
510
private bool HasValue { get { return _header.
IsValid
; } }
512
private T? Value { get { return _header.
IsValid
? _value : default(T); } }
Internal\SourceCore.cs (4)
166
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
222
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
249
if (!messageHeader.
IsValid
) throw new ArgumentException(SR.Argument_InvalidMessageHeader, nameof(messageHeader));
573
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));