Home
last modified time | relevance | path

Searched refs:IPropagatorBlock (Results 1 – 25 of 27) sorted by relevance

12

/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/src/Base/
H A DIPropagatorBlock.cs19 …public interface IPropagatorBlock<in TInput, out TOutput> : ITargetBlock<TInput>, ISourceBlock<TOu… interface
H A DDataflowBlock.cs103 private sealed class FilteredLinkPropagator<T> : IPropagatorBlock<T, T>, IDebuggerDisplay
1618 public static IPropagatorBlock<TInput, TOutput> Encapsulate<TInput, TOutput>( in Encapsulate()
1630 …private sealed class EncapsulatingPropagator<TInput, TOutput> : IPropagatorBlock<TInput, TOutput>,…
/dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/CoreFxSources/Base/
H A DIPropagatorBlock.cs18 …public interface IPropagatorBlock<in TInput, out TOutput> : ITargetBlock<TInput>, ISourceBlock<TOu… interface
H A DDataflowBlock.cs102 private sealed class FilteredLinkPropagator<T> : IPropagatorBlock<T, T>, IDebuggerDisplay
1646 public static IPropagatorBlock<TInput, TOutput> Encapsulate<TInput, TOutput>( in Encapsulate()
1658 …private sealed class EncapsulatingPropagator<TInput, TOutput> : IPropagatorBlock<TInput, TOutput>,…
/dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/
H A DSystem.Threading.Tasks.Dataflow.dll.sources13 CoreFxSources/Base/IPropagatorBlock.cs
/dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/Test/System.Threading.Tasks.Dataflow/
H A DEncapsulateTest.cs76 IPropagatorBlock<TInput, TOutput> {
H A DInvalidArgumentsTest.cs219 IPropagatorBlock<int, int> block = null; in ReactiveTest()
295 IPropagatorBlock<int, int> nullBlock = null; in LinkToTest()
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/ref/
H A DSystem.Threading.Tasks.Dataflow.cs24 …ding.Tasks.Dataflow.IDataflowBlock, System.Threading.Tasks.Dataflow.IPropagatorBlock<T, T[]>, Syst…
82 …ding.Tasks.Dataflow.IDataflowBlock, System.Threading.Tasks.Dataflow.IPropagatorBlock<T, T>, System…
98 …ding.Tasks.Dataflow.IDataflowBlock, System.Threading.Tasks.Dataflow.IPropagatorBlock<T, T>, System…
123 …public static System.Threading.Tasks.Dataflow.IPropagatorBlock<TInput, TOutput> Encapsulate<TInput… in Encapsulate()
199 …public partial interface IPropagatorBlock<in TInput, out TOutput> : System.Threading.Tasks.Dataflo… interface
255 …ding.Tasks.Dataflow.IDataflowBlock, System.Threading.Tasks.Dataflow.IPropagatorBlock<TInput, TOutp…
275 …ding.Tasks.Dataflow.IDataflowBlock, System.Threading.Tasks.Dataflow.IPropagatorBlock<TInput, TOutp…
295 …ding.Tasks.Dataflow.IDataflowBlock, System.Threading.Tasks.Dataflow.IPropagatorBlock<T, T>, System…
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/tests/Dataflow/
H A DDataflowTestHelper.cs243 …internal static IPropagatorBlock<U, U> Chain<T, U>(int numBlocks, Func<T> generate) where T : IPro… property in System.Threading.Tasks.Dataflow.Tests.DataflowTestHelpers
H A DDataflowBlockExtensionTests.cs448 … Assert.Throws<ArgumentNullException>(() => ((IPropagatorBlock<int, int>)null).LinkTo(target)); in TestLinkTo_ArgumentValidation()
453 …Assert.Throws<ArgumentNullException>(() => ((IPropagatorBlock<int, int>)null).LinkTo(null, new Dat… in TestLinkTo_ArgumentValidation()
712 IPropagatorBlock<int, int> source; in TestLinkTo_PropagateCompletion()
1715 IPropagatorBlock<int, int> encapsulated = DataflowBlock.Encapsulate(action, buffer); in TestEncapsulate_LinkingAndUnlinking()
1750 IPropagatorBlock<int, int> encapsulated = DataflowBlock.Encapsulate(transform, buffer); in TestEncapsulate_EncapsulateBoundedTarget()
1772 IPropagatorBlock<int, int> encapsulated1 = DataflowBlock.Encapsulate(action1, buffer1); in TestEncapsulate_ReserveAndRelease()
1777 … IPropagatorBlock<string, string> encapsulated2 = DataflowBlock.Encapsulate(action2, buffer2); in TestEncapsulate_ReserveAndRelease()
1801 IPropagatorBlock<int, int> encapsulated1 = DataflowBlock.Encapsulate(action1, buffer); in TestEncapsulate_Receives()
1814 IPropagatorBlock<int, int> encapsulated2 = DataflowBlock.Encapsulate(action2, buffer); in TestEncapsulate_Receives()
H A DDelegateBasedMocks.cs20 internal class DelegatePropagator<TInput, TOutput> : IPropagatorBlock<TInput, TOutput>
/dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/mono/
H A DSystem.Threading.Tasks.Dataflow.cs77 …ding.Tasks.Dataflow.IDataflowBlock, System.Threading.Tasks.Dataflow.IPropagatorBlock<T, T[]>, Syst…
141 …ding.Tasks.Dataflow.IDataflowBlock, System.Threading.Tasks.Dataflow.IPropagatorBlock<T, T>, System…
159 …ding.Tasks.Dataflow.IDataflowBlock, System.Threading.Tasks.Dataflow.IPropagatorBlock<T, T>, System…
184 …public static System.Threading.Tasks.Dataflow.IPropagatorBlock<TInput, TOutput> Encapsulate<TInput… in Encapsulate()
264 …public partial interface IPropagatorBlock<in TInput, out TOutput> : System.Threading.Tasks.Dataflo… interface
326 …ding.Tasks.Dataflow.IDataflowBlock, System.Threading.Tasks.Dataflow.IPropagatorBlock<TInput, TOutp…
348 …ding.Tasks.Dataflow.IDataflowBlock, System.Threading.Tasks.Dataflow.IPropagatorBlock<TInput, TOutp…
370 …ding.Tasks.Dataflow.IDataflowBlock, System.Threading.Tasks.Dataflow.IPropagatorBlock<T, T>, System…
/dports/lang/mono/mono-5.10.1.57/external/api-snapshot/profiles/net_4_x/
H A DSystem.Threading.Tasks.Dataflow.cs76 …ding.Tasks.Dataflow.IDataflowBlock, System.Threading.Tasks.Dataflow.IPropagatorBlock<T, T[]>, Syst…
140 …ding.Tasks.Dataflow.IDataflowBlock, System.Threading.Tasks.Dataflow.IPropagatorBlock<T, T>, System…
158 …ding.Tasks.Dataflow.IDataflowBlock, System.Threading.Tasks.Dataflow.IPropagatorBlock<T, T>, System…
183 …public static System.Threading.Tasks.Dataflow.IPropagatorBlock<TInput, TOutput> Encapsulate<TInput… in Encapsulate()
263 …public partial interface IPropagatorBlock<in TInput, out TOutput> : System.Threading.Tasks.Dataflo… interface
325 …ding.Tasks.Dataflow.IDataflowBlock, System.Threading.Tasks.Dataflow.IPropagatorBlock<TInput, TOutp…
347 …ding.Tasks.Dataflow.IDataflowBlock, System.Threading.Tasks.Dataflow.IPropagatorBlock<TInput, TOutp…
369 …ding.Tasks.Dataflow.IDataflowBlock, System.Threading.Tasks.Dataflow.IPropagatorBlock<T, T>, System…
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/src/Internal/
H A DTargetRegistry.cs307 … private sealed class NopLinkPropagator : IPropagatorBlock<T, T>, ISourceBlock<T>, IDebuggerDisplay
/dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/CoreFxSources/Internal/
H A DTargetRegistry.cs307 … private sealed class NopLinkPropagator : IPropagatorBlock<T, T>, ISourceBlock<T>, IDebuggerDisplay
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/src/Blocks/
H A DBufferBlock.cs27 …public sealed class BufferBlock<T> : IPropagatorBlock<T, T>, IReceivableSourceBlock<T>, IDebuggerD…
H A DWriteOnceBlock.cs27 …public sealed class WriteOnceBlock<T> : IPropagatorBlock<T, T>, IReceivableSourceBlock<T>, IDebugg…
H A DTransformBlock.cs27 …public sealed class TransformBlock<TInput, TOutput> : IPropagatorBlock<TInput, TOutput>, IReceivab…
H A DTransformManyBlock.cs29 …public sealed class TransformManyBlock<TInput, TOutput> : IPropagatorBlock<TInput, TOutput>, IRece…
H A DBroadcastBlock.cs38 …public sealed class BroadcastBlock<T> : IPropagatorBlock<T, T>, IReceivableSourceBlock<T>, IDebugg…
/dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/CoreFxSources/Blocks/
H A DTransformBlock.cs26 …public sealed class TransformBlock<TInput, TOutput> : IPropagatorBlock<TInput, TOutput>, IReceivab…
H A DBufferBlock.cs26 …public sealed class BufferBlock<T> : IPropagatorBlock<T, T>, IReceivableSourceBlock<T>, IDebuggerD…
H A DWriteOnceBlock.cs26 …public sealed class WriteOnceBlock<T> : IPropagatorBlock<T, T>, IReceivableSourceBlock<T>, IDebugg…
H A DTransformManyBlock.cs28 …public sealed class TransformManyBlock<TInput, TOutput> : IPropagatorBlock<TInput, TOutput>, IRece…
H A DBroadcastBlock.cs37 …public sealed class BroadcastBlock<T> : IPropagatorBlock<T, T>, IReceivableSourceBlock<T>, IDebugg…

12