in jvm/diffuser/src/main/java/com/spotify/diffuser/fuser/Fuser.java [162:172]
public static <A, B> Fuser<B> extractUnlessNull(Function<A, B> transformation, Fuser<A> fuser) {
return from(
dispatch ->
fuser.connect(
a -> {
final B b = transformation.apply(a);
if (b != null) {
dispatch.run(b);
}
}));
}