MCPcopy Create free account
hub / github.com/WinVector/Logistic / FullSerialReducer

Class FullSerialReducer

test/com/winvector/util/FullSerialReducer.java:11–20  ·  view source on GitHub ↗

for testing, force both reducers into serial op @author johnmount @param @param @param

Source from the content-addressed store, hash-verified

9 * @param <Z>
10 */
11public 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}

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected