servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/Completable.java [2104:2115]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private void subscribeWithContext(Subscriber subscriber,
                                      AsyncContextProvider contextProvider, ContextMap contextMap) {
        requireNonNull(subscriber);
        Subscriber wrapped = contextProvider.wrapCancellable(subscriber, contextMap);
        if (contextProvider.context() == contextMap) {
            // No need to wrap as we are sharing the AsyncContext
            handleSubscribe(wrapped, contextMap, contextProvider);
        } else {
            // Ensure that AsyncContext used for handleSubscribe() is the contextMap for the subscribe()
            contextProvider.wrapRunnable(() -> handleSubscribe(wrapped, contextMap, contextProvider), contextMap).run();
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/Single.java [2454:2465]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private void subscribeWithContext(Subscriber<? super T> subscriber,
                                      AsyncContextProvider contextProvider, ContextMap contextMap) {
        requireNonNull(subscriber);
        Subscriber<? super T> wrapped = contextProvider.wrapCancellable(subscriber, contextMap);
        if (contextProvider.context() == contextMap) {
            // No need to wrap as we are sharing the AsyncContext
            handleSubscribe(wrapped, contextMap, contextProvider);
        } else {
            // Ensure that AsyncContext used for handleSubscribe() is the contextMap for the subscribe()
            contextProvider.wrapRunnable(() -> handleSubscribe(wrapped, contextMap, contextProvider), contextMap).run();
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -