Class BeanUsingBufferOverflowStrategy


  • @ApplicationScoped
    public class BeanUsingBufferOverflowStrategy
    extends Object
    • Constructor Detail

      • BeanUsingBufferOverflowStrategy

        public BeanUsingBufferOverflowStrategy()
    • Method Detail

      • terminate

        @PreDestroy
        public void terminate()
      • 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)