@Override
        public void onNext(T o) {
            if (collector == null) {
                collector = new Builder<>();
            }
            collector.add(o);
        }
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