@Override
        public void onError(Throwable cause) {
            onErrorCalled = true;
            future.completeExceptionally(cause);
        }
An abstract {@link Subscriber} implementation which collects objects published by a {@link Publisher}.
core/src/main/java/com/linecorp/armeria/internal/common/util/ObjectCollectingUtil.java