public Throwable getError() {
            if (errors.size() > 0) {
                return errors.get(0);
            }
            return null;
        }
A Subscriber that stores the publishers results and provides a latch so can block on completion.

@param <T> The publishers result type
agent-module/agent-testweb/mongodb-reactive-plugin-testweb/src/main/java/com/pinpoint/test/plugin/SubscriberHelpers.java