void abort(Throwable cause) {
            if (cancelledOrAbortedUpdater.compareAndSet(this, null, cause)) {
                signal();
            }
        }
{@link CancelledSubscriptionException} if cancelled. {@link Throwable} if aborted.
core/src/main/java/com/linecorp/armeria/common/stream/DefaultStreamMessageDuplicator.java