private void doSignal() {
            final SignalQueue signals = processor.signals();
            while (doSignalSingle(signals)) {
                continue;
            }
        }
{@link CancelledSubscriptionException} if cancelled. {@link Throwable} if aborted.
core/src/main/java/com/linecorp/armeria/common/stream/DefaultStreamMessageDuplicator.java