Lines Matching refs:source1
38 var source1 = new BufferBlock<int> (); in BasicTest()
44 source1, _ => action1 = true, in BasicTest()
47 source1.Post (42); in BasicTest()
58 var source1 = new BufferBlock<int> (); in OnlyOneConsumedTest()
64 source1, _ => action1++, in OnlyOneConsumedTest()
67 source1.Post (42); in OnlyOneConsumedTest()
68 source1.Post (43); in OnlyOneConsumedTest()
76 Assert.IsTrue (source1.TryReceive (out item)); in OnlyOneConsumedTest()
83 var source1 = new BufferBlock<int> (); in RaceTest()
89 source1, _ => action1++, in RaceTest()
97 source1.Post (10); in RaceTest()
111 Assert.IsTrue (source1.TryReceive (out item) || source2.TryReceive (out item)); in RaceTest()
117 var source1 = new BufferBlock<int> (); in BlockCompletionTest()
121 source1, _ => { }, source2, _ => { }); in BlockCompletionTest()
125 ((IDataflowBlock)source1).Fault (new Exception ()); in BlockCompletionTest()
136 var source1 = new BufferBlock<int> (); in CancellationTest()
144 source1, _ => { }, source2, _ => { }, options); in CancellationTest()
158 var source1 = new BroadcastBlock<int> (_ => 42); in ConsumeToAcceptTest()
164 source1, i => action1 = i, in ConsumeToAcceptTest()
167 source1.Post (10); in ConsumeToAcceptTest()
178 var source1 = new BufferBlock<int> (); in ExceptionTest()
183 source1, _ => { throw exception; }, in ExceptionTest()
186 source1.Post (42); in ExceptionTest()
196 var source1 = new BufferBlock<int> (); in BasicTest_3()
204 source1, _ => action1 = true, in BasicTest_3()