com_baeldung_rxjava_UtilityOperatorsIntegrationTest_java
rx.internal.operators.OperatorObserveOn$ObserveOnSubscriber
 -> java.util.concurrent.atomic.AtomicLong.getAndIncrement(): long -> java.util.concurrent.atomic.AtomicReference.get(): java.lang.Object -> java.util.concurrent.atomic.AtomicReference.get(): java.lang.Object -> java.util.List.add(java.lang.Object): boolean -> java.util.List.add(java.lang.Object): boolean -> java.util.concurrent.ScheduledExecutorService.submit(java.lang.Runnable): java.util.concurrent.Future -> java.lang.StringBuilder.append(java.lang.String): java.lang.StringBuilder -> java.lang.StringBuilder.append(long): java.lang.StringBuilder -> java.lang.StringBuilder.toString(): java.lang.String -> java.lang.Thread.setDaemon(boolean): void -> java.util.concurrent.Future.isCancelled(): boolean -> java.util.concurrent.Future.cancel(boolean): boolean