APISonar


reactor.core.publisher.EmitterProcessor.log

> reactor > core > publisher > EmitterProcessor > log
reactor APIs core APIs publisher APIs EmitterProcessor APIs log APIs

Example 1
EmitterProcessor<Long> emitter1;

	public void mergeWithNoInterleave() throws Exception{
		Flux.concat(emitter1.log("test1"), emitter2.log("test2")).log().subscribe(ts);
		emitValues();
		ts.assertValues(1L, 3L, 2L, 4L).assertComplete();
	}