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)
42
return source.LinkTo(target,
DataflowLinkOptions
.Default);
59
return LinkTo(source, target,
DataflowLinkOptions
.Default, predicate);
75
DataflowLinkOptions
linkOptions,
185
IDisposable ISourceBlock<T>.LinkTo(ITargetBlock<T> target,
DataflowLinkOptions
linkOptions) { throw new NotSupportedException(SR.NotSupported_MemberNotNeeded); }
712
IDisposable ISourceBlock<TOutput>.LinkTo(ITargetBlock<TOutput> target,
DataflowLinkOptions
linkOptions) { throw new NotSupportedException(SR.NotSupported_MemberNotNeeded); }
1077
IDisposable unlink = source.LinkTo(target,
DataflowLinkOptions
.UnlinkAfterOneAndPropagateCompletion);
1422
using (source.LinkTo(target,
DataflowLinkOptions
.UnlinkAfterOneAndPropagateCompletion))
1556
public IDisposable LinkTo(ITargetBlock<TOutput> target,
DataflowLinkOptions
linkOptions)
2016
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)
121
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)
378
public IDisposable LinkTo(ITargetBlock<Tuple<IList<T1>, IList<T2>, IList<T3>>> target,
DataflowLinkOptions
linkOptions)
Blocks\BroadcastBlock.cs (2)
148
public IDisposable LinkTo(ITargetBlock<T> target,
DataflowLinkOptions
linkOptions) { return _source.LinkTo(target, linkOptions); }
1003
internal IDisposable LinkTo(ITargetBlock<TOutput> target,
DataflowLinkOptions
linkOptions)
Blocks\BufferBlock.cs (1)
183
public IDisposable LinkTo(ITargetBlock<T> target,
DataflowLinkOptions
linkOptions) { return _source.LinkTo(target, linkOptions); }
Blocks\JoinBlock.cs (2)
110
public IDisposable LinkTo(ITargetBlock<Tuple<T1, T2>> target,
DataflowLinkOptions
linkOptions)
329
public IDisposable LinkTo(ITargetBlock<Tuple<T1, T2, T3>> target,
DataflowLinkOptions
linkOptions)
Blocks\TransformBlock.cs (1)
341
public IDisposable LinkTo(ITargetBlock<TOutput> target,
DataflowLinkOptions
linkOptions)
Blocks\TransformManyBlock.cs (1)
556
public IDisposable LinkTo(ITargetBlock<TOutput> target,
DataflowLinkOptions
linkOptions) { return _source.LinkTo(target, linkOptions); }
Blocks\WriteOnceBlock.cs (1)
297
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); }