Class EventPublisher.EventCallable

  • All Implemented Interfaces:
    java.util.concurrent.Callable<java.lang.Void>
    Enclosing class:
    EventPublisher

    class EventPublisher.EventCallable
    extends java.lang.Object
    implements java.util.concurrent.Callable<java.lang.Void>
    Event processing task which is submit to a ExecutorService for processing.
    • Constructor Detail

    • Method Detail

      • call

        public java.lang.Void call()
        Specified by:
        call in interface java.util.concurrent.Callable<java.lang.Void>
      • handleEvent

        private void handleEvent​(java.util.concurrent.Flow.Subscriber<java.util.Map<java.lang.String,​java.lang.Object>> subscriber,
                                 JsonRpcEvent event)