APISonar


reactor.core.publisher.FluxProcessor.log

> reactor > core > publisher > FluxProcessor > log
reactor APIs core APIs publisher APIs FluxProcessor APIs log APIs

Example 1
public Processor<Long, Long> createIdentityProcessor(int bufferSize) {
		FluxProcessor<Long, Long> p = EmitterProcessor.create(bufferSize);
		return FluxProcessor.wrap(p, p.log("EmitterProcessorVerification", Level.FINE));
	}