public static interface OpTestCase.BaseStreamTestScenario
Modifier and Type | Method and Description |
---|---|
StreamShape |
getShape() |
boolean |
isOrdered() |
boolean |
isParallel() |
<T,U,S_IN extends BaseStream<T,S_IN>,S_OUT extends BaseStream<U,S_OUT>> |
run(TestData<T,S_IN> data,
Consumer<U> b,
Function<S_IN,S_OUT> m) |
StreamShape getShape()
boolean isParallel()
boolean isOrdered()
<T,U,S_IN extends BaseStream<T,S_IN>,S_OUT extends BaseStream<U,S_OUT>> void run(TestData<T,S_IN> data, Consumer<U> b, Function<S_IN,S_OUT> m)