Lines Matching defs:chain
223 return new ExerciseDataStreamBuilder<>(data, (S_IN s) -> (S_OUT) chain(s, ops));
233 return new ExerciseDataStreamBuilder<>(data, s -> (S_OUT) chain(m.apply(s), additionalOp));
461 source = (BaseStream) chain(source, new ShortCircuitOp(shape));
473 source = (BaseStream) chain(source, new ShortCircuitOp(shape));
617 private static <T> AbstractPipeline<?, T, ?> chain(AbstractPipeline upstream, IntermediateTestOp<?, T> op) {
618 return (AbstractPipeline<?, T, ?>) IntermediateTestOp.chain(upstream, op);
622 private static AbstractPipeline<?, ?, ?> chain(AbstractPipeline pipe, IntermediateTestOp... ops) {
624 pipe = chain(pipe, op);
629 private static <T> AbstractPipeline<?, T, ?> chain(BaseStream pipe, IntermediateTestOp<?, T> op) {
630 return chain((AbstractPipeline) pipe, op);
634 public static AbstractPipeline<?, ?, ?> chain(BaseStream pipe, IntermediateTestOp... ops) {
635 return chain((AbstractPipeline) pipe, ops);