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.
java.lang.AutoCloseable open(PushEventConsumer<? super T> aec) throws java.lang.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.
aec- the consumer (not null)
AutoCloseablethat can be used to close the stream
Copyright © OSGi Alliance (2000, 2018). All Rights Reserved. Licensed under the OSGi Specification License, Version 2.0