Class BeanUsingBufferOverflowStrategy
- java.lang.Object
-
- org.eclipse.microprofile.reactive.messaging.tck.channel.overflow.BeanUsingBufferOverflowStrategy
-
@ApplicationScoped public class BeanUsingBufferOverflowStrategy extends Object
-
-
Constructor Summary
Constructors Constructor Description BeanUsingBufferOverflowStrategy()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description List<String>
accepted()
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<String>
consume(org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<String> values)
Throwable
failure()
void
out(String s)
List<String>
output()
List<String>
rejected()
void
terminate()
void
tryEmitThousand()
void
tryEmitThree()
-
-
-
Method Detail
-
terminate
@PreDestroy public void terminate()
-
failure
public Throwable failure()
-
tryEmitThree
public void tryEmitThree()
-
tryEmitThousand
public void tryEmitThousand()
-
consume
public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<String> consume(org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<String> values)
-
out
public void out(String s)
-
-