AbstractPushablePublisher (cyclops-reactor 8.4.2 API)

java.lang.Object
- org.jooq.lambda.tuple.Tuple2<X,R>
- - com.aol.cyclops.reactor.flux.pushable.AbstractPushablePublisher<T,X,R>

Field Summary
- Fields inherited from class org.jooq.lambda.tuple.Tuple2
  v1, v2

Constructors
Constructor and Description
`AbstractPushablePublisher(X v1, R v2)`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`R`	`getFlux()`
`X`	`getInput()`
`void`	`peekFlux(java.util.function.Consumer<? super R> consumer)`
`void`	`peekInput(java.util.function.Consumer<? super X> consumer)`
`<U> U`	`visit(java.util.function.BiFunction<? super X,? super R,? extends U> visitor)`

Methods inherited from class org.jooq.lambda.tuple.Tuple2
array, clone, compareTo, concat, concat, concat, concat, concat, concat, concat, concat, concat, concat, concat, concat, concat, concat, concat, degree, equals, hashCode, intersect, iterator, limit0, limit1, limit2, list, map, map1, map2, overlaps, skip0, skip1, skip2, split0, split1, split2, swap, toArray, toList, toMap, toMap, toMap, toMap, toSeq, toString, v1, v2

Methods inherited from class java.lang.Object
finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.jooq.lambda.tuple.Tuple
collectors, collectors, collectors, collectors, collectors, collectors, collectors, collectors, collectors, collectors, collectors, collectors, collectors, collectors, collectors, collectors, consumer, consumer, consumer, consumer, consumer, consumer, consumer, consumer, consumer, consumer, consumer, consumer, consumer, consumer, consumer, consumer, consumer, function, function, function, function, function, function, function, function, function, function, function, function, function, function, function, function, function, range, tuple, tuple, tuple, tuple, tuple, tuple, tuple, tuple, tuple, tuple, tuple, tuple, tuple, tuple, tuple, tuple, tuple

public AbstractPushablePublisher(X v1,
                                 R v2)

public <U> U visit(java.util.function.BiFunction<? super X,? super R,? extends U> visitor)

public void peekFlux(java.util.function.Consumer<? super R> consumer)

public void peekInput(java.util.function.Consumer<? super X> consumer)

Class AbstractPushablePublisher<T,X extends Adapter<T>,R extends org.reactivestreams.Publisher<T>>