private Mono<Void> write(Flux<? extends DataBuffer> publisher) {
        return Mono.deferContextual(contextView -> {
            final HttpResponse response =
                    HttpResponse.of(armeriaHeaders.build(),
                                    publisher.map(factoryWrapper::toHttpData)
                                             .contextWrite(contextView)
                                             .doOnDiscard(PooledDataBuffer.class, DataBufferUtils::release)
                    );
            future.complete(response);
            return Mono.fromFuture(response.whenComplete())
                       .onErrorResume(cause -> cause instanceof CancelledSubscriptionException ||
                                               cause instanceof AbortedStreamException,
                                      cause -> Mono.empty());
        });
    }
A {@link ServerHttpResponse} implementation for the Armeria HTTP server.
spring/boot3-webflux-autoconfigure/src/main/java/com/linecorp/armeria/spring/web/reactive/ArmeriaServerHttpResponse.java