| 1 | package com.github.valid8j.metamor.internals; | |
| 2 | ||
| 3 | import com.github.valid8j.metamor.Dataset; | |
| 4 | import com.github.valid8j.metamor.IoContext; | |
| 5 | ||
| 6 | import java.util.function.Function; | |
| 7 | import java.util.function.IntFunction; | |
| 8 | ||
| 9 | public enum InternalUtils { | |
| 10 | ; | |
| 11 | ||
| 12 | public static <I, O> Function<Dataset<I>, Dataset<O>> createObservableProcessingPipeline(String contextName, Function<IoContext<I, O>, Function<I, O>> mapper, int numItems, IntFunction<String> variableNameFormatter, String outputContextName) { | |
| 13 |
1
1. createObservableProcessingPipeline : replaced return value with null for com/github/valid8j/metamor/internals/InternalUtils::createObservableProcessingPipeline → KILLED |
return IoContext.Utils.<I, O>toContextFunction(contextName, outputContextName) |
| 14 | .andThen(IoContext.Utils.toContextEndomorphicFunction(mapper, numItems, variableNameFormatter)) | |
| 15 | .andThen(IoContext.Utils.toCloseFunction(contextName)) | |
| 16 | .andThen(IoContext.Utils.toOutputExtractorFunction(contextName)); | |
| 17 | } | |
| 18 | } | |
Mutations | ||
| 13 |
1.1 |