private Subscriber<? super T> requiredWriteSubscriber() {
            checkState(writeSubscriber != null, "No write subscriber");
            return writeSubscriber;
        }
The actual writeSubscriber from the HTTP server adapter.
spring/boot3-webflux-autoconfigure/src/main/java/com/linecorp/armeria/spring/web/reactive/ChannelSendOperator.java