Interface PublisherPipe<T,U>

Type Parameters:
T - the type of the value emitted by the publisher to transform
U - the type of the value emitted by the resulting publisher
All Superinterfaces:
Function<Publisher<T>,Publisher<U>>, Pipe<Publisher<T>,Publisher<U>>
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface public interface PublisherPipe<T,U> extends Pipe<Publisher<T>,Publisher<U>>

A publisher pipe is used within a template to transform a publisher before applying templates to the emitted elements.

Since:
1.2
Author:
Jeremy Kuhn
  • Method Summary

    Modifier and Type
    Method
    Description
    default <V> PublisherPipe<T,V>
    and(PublisherPipe<U,V> after)
    Chains the specified publisher pipe after this pipe.

    Methods inherited from interface java.util.function.Function

    andThen, apply, compose

    Methods inherited from interface io.inverno.mod.irt.Pipe

    and
  • Method Details

    • and

      default <V> PublisherPipe<T,V> and(PublisherPipe<U,V> after)

      Chains the specified publisher pipe after this pipe.

      Type Parameters:
      V - the type of the value emitted by the resulting publisher
      Parameters:
      after - the publisher pipe to chain after this pipe
      Returns:
      A publisher pipe which first invokes this pipe and then the after pipe