default Publisher pipe()

in component-dsl/src/main/java/org/apache/aries/component/dsl/Publisher.java [38:53]

• 13 lines of code
• 1 McCabe index (conditional complexity)

    default <S> Publisher<S> pipe(Function<? super S, OSGiResult> next) {

        return new Publisher<S>() {
            @Override
            public OSGiResult publish(S t) {
                return next.apply(t);
            }

            @SuppressWarnings("unchecked")
            @Override
            public <E extends Exception> OSGiResult error(S s, Exception e) throws E {
                return Publisher.this.error((T)s, e);
            }
        };

    }