for testing, force both reducers into serial op @author johnmount @param @param @param
| 9 | * @param <Z> |
| 10 | */ |
| 11 | public final class FullSerialReducer<T, S extends SerialObserver<T>, Z extends ReducibleObserver<T,Z>> { |
| 12 | public void reduce(final Iterable<? extends T> dat, final S serialObserver, final Z parallelObserver) { |
| 13 | for(final T t: dat) { |
| 14 | if(null!=serialObserver) { |
| 15 | serialObserver.observe(t); |
| 16 | } |
| 17 | parallelObserver.observe(t); |
| 18 | } |
| 19 | } |
| 20 | } |
nothing calls this directly
no outgoing calls
no test coverage detected