Subscriber<Object> subscriber() {
            return subscriber;
        }
Returns newly created {@link CloseEvent} if the specified {@link Throwable} is not an instance of
{@link CancelledSubscriptionException#INSTANCE} or {@link AbortedStreamException#INSTANCE}.
core/src/main/java/com/linecorp/armeria/common/stream/CancellableStreamMessage.java