once is like: ``` amb( upstream.filter(whatever ...
# rx
j
once is like:
Copy code
amb(
  upstream.filter(whatever -> whatever > threshold)
      .concat(just(null)),
  timer(3, SECONDS).map(ignored -> null)
).filter(it -> it == null)