ConsumingRouter.java

import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.function.Consumer;
import java.util.function.Predicate;

public class ConsumingRouter<T> implements Consumer<T> {
	private Map<Predicate<T>, Consumer<T>> map = new ConcurrentHashMap<>();

	public void sub(Predicate<T> p, Consumer<T> c) {
		map.put(p, c);
	}

	@Override
	public void accept(T t) {
		map.entrySet().forEach(e -> {
			if (e.getKey().test(t))
				e.getValue().accept(t);
		});
	}
}