Package io.smallrye.mutiny.streams.operators

Class Operator<T extends org.eclipse.microprofile.reactive.streams.operators.spi.Stage>

java.lang.Object

io.smallrye.mutiny.streams.operators.Operator<T>

All Implemented Interfaces:

Predicate<org.eclipse.microprofile.reactive.streams.operators.spi.Stage>

Direct Known Subclasses:

ProcessorOperator, PublisherOperator, TerminalOperator

public class Operator<T extends org.eclipse.microprofile.reactive.streams.operators.spi.Stage>
extends Object
implements Predicate<org.eclipse.microprofile.reactive.streams.operators.spi.Stage>

Method Summary

Modifier and Type	Method	Description
boolean	test(org.eclipse.microprofile.reactive.streams.operators.spi.Stage s)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.Predicate

and, negate, or

Method Details

test

public boolean test(org.eclipse.microprofile.reactive.streams.operators.spi.Stage s)

Specified by:

test in interface Predicate<T extends org.eclipse.microprofile.reactive.streams.operators.spi.Stage>