jw
amb( upstream.filter(whatever -> whatever > threshold) .concat(just(null)), timer(3, SECONDS).map(ignored -> null) ).filter(it -> it == null)