public class FlagOpTest extends OpTestCase
OpTestCase.BaseStreamTestScenario, OpTestCase.DataStreamBuilder<T,S_IN extends BaseStream<T,S_IN>>, OpTestCase.ExerciseDataStreamBuilder<T,U,S_IN extends BaseStream<T,S_IN>,S_OUT extends BaseStream<U,S_OUT>>, OpTestCase.ExerciseDataTerminalBuilder<T,U,R,S_IN extends BaseStream<T,S_IN>,S_OUT extends BaseStream<U,S_OUT>>, OpTestCase.ResultAsserter<R>
Constructor and Description |
---|
FlagOpTest() |
Modifier and Type | Method and Description |
---|---|
void |
testFlagsClearAllSet() |
void |
testFlagsClearParallelCollect() |
protected void |
testFlagsClearSequence(Supplier<java.util.stream.StatefulTestOp<Integer>> cf) |
void |
testFlagsParallelCollect() |
void |
testFlagsPassThrough(String name,
TestData<Integer,Stream<Integer>> data) |
void |
testFlagsSetAllClear() |
void |
testFlagsSizedOrderedParallelCollect() |
chain, exerciseOps, exerciseOps, exerciseOps, exerciseOps, exerciseOps, exerciseOpsInt, exerciseOpsMulti, exerciseTerminalOps, exerciseTerminalOps, exerciseTerminalOps, exerciseTerminalOpsInt, exerciseTerminalOpsMulti, getStreamFlags, withData
after, before, clearContext, setContext
public void testFlagsPassThrough(String name, TestData<Integer,Stream<Integer>> data)
public void testFlagsClearAllSet()
public void testFlagsSetAllClear()
public void testFlagsParallelCollect()
public void testFlagsClearParallelCollect()
protected void testFlagsClearSequence(Supplier<java.util.stream.StatefulTestOp<Integer>> cf)
public void testFlagsSizedOrderedParallelCollect()