private static void handleLateSubscriber(Subscriber<?> lateSubscriber, Throwable cause) {
        try {
            lateSubscriber.onSubscribe(NoopSubscription.get());
            lateSubscriber.onError(cause);
        } catch (Throwable t) {
            throwIfFatal(t);
            logger.warn("Subscriber should not throw an exception. subscriber: {}", lateSubscriber, t);
        }
    }
Invoked after an element is removed from the {@link StreamMessage} and before
{@link Subscriber#onNext(Object)} is invoked.

@param obj the removed element
core/src/main/java/com/linecorp/armeria/common/stream/CancellableStreamMessage.java