Method run

src/com/winvector/util/ThreadedReducer.java:38–50

()

		}

		@Override
		public void run() {
			final Z r;
			synchronized (baseRes) {
				r = baseRes.newObserver();
			}
			for(final T di: sourcei) {
				r.observe(di);
			}
			synchronized (baseRes) {
				baseRes.observe(r);
			}
		}
		
	}