Package org.eclipse.ditto.services.utils.search

Class SearchSource

java.lang.Object

org.eclipse.ditto.services.utils.search.SearchSource

public final class SearchSource
extends Object

Source of search results for one query.

Method Summary

Modifier and Type	Method	Description
static SearchSourceBuilder	newBuilder()	Create a new builder.
akka.stream.javadsl.Source<org.eclipse.ditto.json.JsonObject,akka.NotUsed>	start(Consumer<org.eclipse.ditto.services.utils.akka.controlflow.ResumeSourceBuilder<?,?>> configurer)	Start a source of search results.
akka.stream.javadsl.Source<akka.japi.Pair<String,org.eclipse.ditto.json.JsonObject>,akka.NotUsed>	startAsPair(Consumer<org.eclipse.ditto.services.utils.akka.controlflow.ResumeSourceBuilder<?,?>> configurer)	Start a robust source of search results paired with their IDs.

Methods inherited from class java.lang.Object

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

Method Detail

newBuilder

public static SearchSourceBuilder newBuilder()

Create a new builder.

Returns:

a new builder.

start

public akka.stream.javadsl.Source<org.eclipse.ditto.json.JsonObject,akka.NotUsed> start(Consumer<org.eclipse.ditto.services.utils.akka.controlflow.ResumeSourceBuilder<?,?>> configurer)

Start a source of search results.

Returns:

the source of search results.

startAsPair

public akka.stream.javadsl.Source<akka.japi.Pair<String,org.eclipse.ditto.json.JsonObject>,akka.NotUsed> startAsPair(Consumer<org.eclipse.ditto.services.utils.akka.controlflow.ResumeSourceBuilder<?,?>> configurer)

Start a robust source of search results paired with their IDs.

Parameters:

configurer - consumer to configure the resume source.

Returns:

source of pair of ID-result pairs where the ID can be used for resumption.