com_baeldung_reactor_creation_SequenceUnitTest_java
com.baeldung.reactor.creation.SequenceGenerator
() -> Tuples.of(0, 1),                 (state, sink) -> {                     sink.next(state.getT1());                     return Tuples.of(state.getT2(), state.getT1() + state.getT2());

 -> java.util.Queue.peek(): java.lang.Object -> java.util.Queue.peek(): java.lang.Object -> java.util.Queue.poll(): java.lang.Object -> java.util.function.BiFunction.apply(java.lang.Object,java.lang.Object): java.lang.Object -> java.util.Objects.equals(java.lang.Object,java.lang.Object): boolean -> java.util.Optional.empty(): java.util.Optional -> java.util.Optional.isPresent(): boolean -> java.util.Queue.peek(): java.lang.Object -> java.util.concurrent.atomic.AtomicLongFieldUpdater.getAndIncrement(java.lang.Object): long -> java.util.Queue.peek(): java.lang.Object -> java.util.Queue.peek(): java.lang.Object -> java.util.Queue.poll(): java.lang.Object -> java.util.function.BiFunction.apply(java.lang.Object,java.lang.Object): java.lang.Object -> java.util.Optional.empty(): java.util.Optional -> java.util.Optional.isPresent(): boolean -> java.util.Queue.peek(): java.lang.Object -> java.util.concurrent.CountDownLatch.countDown(): void -> java.lang.Integer.intValue(): int -> java.lang.Integer.intValue(): int -> java.lang.Integer.valueOf(int): java.lang.Integer -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object