Class CurrentThreadWorkerEventStream

  • All Implemented Interfaces:
    Closeable, AutoCloseable, Iterable<Event>, EventStream, RemotableOverRaw

    public class CurrentThreadWorkerEventStream
    extends Object
    implements EventStream, RemotableOverRaw
    Expands the results from a Reader using the current thread. This is the default strategy for most retrievals; especially if the data sizes are large; here, we leverage streaming to minimize memory consumption. We only support one iterator for this stream.