Skip to content

Instantly share code, notes, and snippets.

@vinsguru

vinsguru/integerflux.java

Created October 25, 2020 16:50
Show Gist options
  • Save vinsguru/b3326226bac2689cadfeed4e547561ef to your computer and use it in GitHub Desktop.
Save vinsguru/b3326226bac2689cadfeed4e547561ef to your computer and use it in GitHub Desktop.
Download ZIP
Raw
integerflux.java
//First observer. takes 1 ms to process each element
integerFlux.delayElements(Duration.ofMillis(1)).subscribe(i -> System.out.println("First :: " + i));
//Second observer. takes 2 ms to process each element
integerFlux.delayElements(Duration.ofMillis(2)).subscribe(i -> System.out.println("Second:: " + i));
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment