Class BeanUsingDropOverflowStrategy


  • @ApplicationScoped
    public class BeanUsingDropOverflowStrategy
    extends Object
    • Constructor Detail

      • BeanUsingDropOverflowStrategy

        public BeanUsingDropOverflowStrategy()
    • Method Detail

      • terminate

        @PreDestroy
        public void terminate()
      • isDone

        public boolean isDone()
      • emitThree

        public void emitThree()
      • emitALotOfItems

        public void emitALotOfItems()
      • 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)