`skip()` filters the beginning of a Project Reactor `Flux`. Give it an item count to discard that many source elements; the resulting `Flux` emits the rest. section 11.3.3
@Test
public void skipAFew() {
Flux<String> countFlux = Flux.just(
"one", "two", "skip a few", "ninety nine", "one hundred")
.skip(3);
StepVerifier.create(countFlux)
.expectNext("ninety nine", "one hundred")
.verifyComplete();
}
In this test, `skip(3)` drops the first three strings. `StepVerifier` checks that only the final two are emitted. section 11.3.3
To skip by time instead, pass a `Duration`. With elements delayed one second apart, `skip(Duration.ofSeconds(4))` leaves the final two strings. Use `take()` for the opposite choice: emitting the first items rather than skipping them. section 11.3.3
@Test
public void skipAFewSeconds() {
Flux<String> countFlux = Flux.just(
"one", "two", "skip a few", "ninety nine", "one hundred")
.delayElements(Duration.ofSeconds(1))
.skip(Duration.ofSeconds(4));
StepVerifier.create(countFlux)
.expectNext("ninety nine", "one hundred")
.verifyComplete();
}
The timed test combines `delayElements()`, `skip(Duration.ofSeconds(4))`, and `StepVerifier` to check what remains. section 11.3.3
