eu.fbk.knowledgestore.elastic

Class SearchResponseStream

java.lang.Object

eu.fbk.knowledgestore.data.Stream<Record>

eu.fbk.knowledgestore.elastic.SearchResponseStream

All Implemented Interfaces:

Closeable, AutoCloseable, Iterable<Record>

public class SearchResponseStream
extends Stream<Record>

Author:

enrico

Method Summary

Modifier and Type	Method and Description
protected void	doToHandler(Handler<? super Record> handler) Implementation methods responsible of forwarding all the elements of the Stream to the Handler specified.

Methods inherited from class eu.fbk.knowledgestore.data.Stream

chunk, close, concat, concat, count, create, create, create, create, create, distinct, doClose, doIterator, doToString, filter, finalize, getProperty, getTimeout, getUnique, getUnique, isAvailable, isClosed, iterator, onClose, setProperty, setTimeout, slice, toArray, toCollection, toHandler, toList, toMap, toMap, toMultimap, toMultimap, toSet, toSortedList, toSortedList, toSortedSet, toString, track, transform, transform, transform

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Method Detail

doToHandler

protected void doToHandler(Handler<? super Record> handler)
                    throws Throwable

Description copied from class: Stream

Implementation methods responsible of forwarding all the elements of the Stream to the Handler specified. This method is called by Stream.toHandler(Handler) to perform internal iteration, with the guarantee that it is called at most once and with the Stream in the available state. As a best practice, the method should intercept Thread.interrupt() requests and stop iteration, if possible; also remember to call Handler.handle(Object) with a null argument after the last element is reached, in order to signal the end of the sequence.

Overrides:

doToHandler in class Stream<Record>

Parameters:

handler - the Handler where to forward elements

Throws:

Throwable - in case of failure