@ApplicationScoped public class BeanUsingBufferOverflowStrategy extends Object
Constructor and Description |
---|
BeanUsingBufferOverflowStrategy() |
Modifier and Type | Method and 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() |
@PreDestroy public void terminate()
public Throwable failure()
public void tryEmitThree()
public void tryEmitThousand()
public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<String> consume(org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<String> values)
public void out(String s)
Copyright © 2018 – 2022 Eclipse Foundation. All rights reserved.
Use is subject to license terms.