public Pad()

in component-dsl/src/main/java/org/apache/aries/component/dsl/internal/Pad.java [34:50]

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

    public Pad(
        ExecutionContext executionContext,
        Function<OSGi<T>, OSGi<S>> fun,
        Publisher<? super S> continuation) {

        ProbeImpl<T> probe = new ProbeImpl<>();

        OSGi<S> next = fun.apply(probe);

        _result = next.run(executionContext, continuation);

        _publisher = continuation.pipe(
            probe.getPublisher() != null ?
                probe.getPublisher()::publish :
                __ -> NOOP
        );
    }