T- The payload type
@ConsumerType @FunctionalInterface public interface PushEventSource<T>
PushEventConsumer.ABORT. Values that are larger than 0 should be treated as a request to delay the next events with those number of milliseconds.
AutoCloseable open(PushEventConsumer<? super T> aec) throws Exception
AutoCloseable. This can be closed, and should close the channel, including sending a Close event if the channel was not already closed. The returned object must be able to be closed multiple times without sending more than one Close events.
Copyright © Contributors to the Eclipse Foundation Licensed under the Eclipse Foundation Specification License – v1.0