2 instantiations of DataflowLinkOptions
System.Threading.Tasks.Dataflow (2)
Base\DataflowLinkOptions.cs (2)
66
internal static readonly DataflowLinkOptions Default = new
DataflowLinkOptions
();
72
internal static readonly DataflowLinkOptions UnlinkAfterOneAndPropagateCompletion = new
DataflowLinkOptions
() { MaxMessages = 1, PropagateCompletion = true };
34 references to DataflowLinkOptions
System.Threading.Tasks.Dataflow (34)
Base\DataflowBlock.cs (9)
48
return source.LinkTo(target,
DataflowLinkOptions
.Default);
65
return LinkTo(source, target,
DataflowLinkOptions
.Default, predicate);
81
DataflowLinkOptions
linkOptions,
203
IDisposable ISourceBlock<T>.LinkTo(ITargetBlock<T> target,
DataflowLinkOptions
linkOptions) { throw new NotSupportedException(SR.NotSupported_MemberNotNeeded); }
736
IDisposable ISourceBlock<TOutput>.LinkTo(ITargetBlock<TOutput> target,
DataflowLinkOptions
linkOptions) { throw new NotSupportedException(SR.NotSupported_MemberNotNeeded); }
1110
IDisposable unlink = source.LinkTo(target,
DataflowLinkOptions
.UnlinkAfterOneAndPropagateCompletion);
1455
using (source.LinkTo(target,
DataflowLinkOptions
.UnlinkAfterOneAndPropagateCompletion))
1601
public IDisposable LinkTo(ITargetBlock<TOutput> target,
DataflowLinkOptions
linkOptions)
2097
unlink = source.LinkTo(target,
DataflowLinkOptions
.UnlinkAfterOneAndPropagateCompletion);
Base\DataflowLinkOptions.cs (9)
23
/// <see cref="
DataflowLinkOptions
"/> is mutable and can be configured through its properties.
44
/// <see cref="
DataflowLinkOptions
"/> instance should not affect the behavior of a link.
50
/// A constant used to specify an unlimited quantity for <see cref="
DataflowLinkOptions
"/> members
51
/// that provide an upper bound. This field is a constant tied to <see cref="
DataflowLinkOptions
.Unbounded"/>.
62
/// <summary>A default instance of <see cref="
DataflowLinkOptions
"/>.</summary>
66
internal static readonly
DataflowLinkOptions
Default = new DataflowLinkOptions();
68
/// <summary>A cached instance of <see cref="
DataflowLinkOptions
"/>.</summary>
72
internal static readonly
DataflowLinkOptions
UnlinkAfterOneAndPropagateCompletion = new DataflowLinkOptions() { MaxMessages = 1, PropagateCompletion = true };
74
/// <summary>Initializes the <see cref="
DataflowLinkOptions
"/>.</summary>
Base\ISourceBlock.cs (1)
25
IDisposable LinkTo(ITargetBlock<TOutput> target,
DataflowLinkOptions
linkOptions);
Blocks\BatchBlock.cs (1)
124
public IDisposable LinkTo(ITargetBlock<T[]> target,
DataflowLinkOptions
linkOptions)
Blocks\BatchedJoinBlock.cs (2)
126
public IDisposable LinkTo(ITargetBlock<Tuple<IList<T1>, IList<T2>>> target,
DataflowLinkOptions
linkOptions)
381
public IDisposable LinkTo(ITargetBlock<Tuple<IList<T1>, IList<T2>, IList<T3>>> target,
DataflowLinkOptions
linkOptions)
Blocks\BroadcastBlock.cs (2)
154
public IDisposable LinkTo(ITargetBlock<T> target,
DataflowLinkOptions
linkOptions) { return _source.LinkTo(target, linkOptions); }
1009
internal IDisposable LinkTo(ITargetBlock<TOutput> target,
DataflowLinkOptions
linkOptions)
Blocks\BufferBlock.cs (1)
189
public IDisposable LinkTo(ITargetBlock<T> target,
DataflowLinkOptions
linkOptions) { return _source.LinkTo(target, linkOptions); }
Blocks\JoinBlock.cs (2)
113
public IDisposable LinkTo(ITargetBlock<Tuple<T1, T2>> target,
DataflowLinkOptions
linkOptions)
338
public IDisposable LinkTo(ITargetBlock<Tuple<T1, T2, T3>> target,
DataflowLinkOptions
linkOptions)
Blocks\TransformBlock.cs (1)
347
public IDisposable LinkTo(ITargetBlock<TOutput> target,
DataflowLinkOptions
linkOptions)
Blocks\TransformManyBlock.cs (1)
559
public IDisposable LinkTo(ITargetBlock<TOutput> target,
DataflowLinkOptions
linkOptions) { return _source.LinkTo(target, linkOptions); }
Blocks\WriteOnceBlock.cs (1)
303
public IDisposable LinkTo(ITargetBlock<T> target,
DataflowLinkOptions
linkOptions)
Internal\SourceCore.cs (1)
124
internal IDisposable LinkTo(ITargetBlock<TOutput> target,
DataflowLinkOptions
linkOptions)
Internal\TargetRegistry.cs (3)
35
internal LinkedTargetInfo(ITargetBlock<T> target,
DataflowLinkOptions
linkOptions)
83
internal void Add(ref ITargetBlock<T> target,
DataflowLinkOptions
linkOptions)
353
IDisposable ISourceBlock<T>.LinkTo(ITargetBlock<T> target,
DataflowLinkOptions
linkOptions) { throw new NotSupportedException(SR.NotSupported_MemberNotNeeded); }