eu.semagrow.core.impl.evaluation.rx.rxjava

Class OnSubscribeTupleResults.TupleQueryResultProducer

java.lang.Object

eu.semagrow.core.impl.evaluation.rx.rxjava.OnSubscribeTupleResults.TupleQueryResultProducer

All Implemented Interfaces:

org.openrdf.query.QueryResultHandler, org.openrdf.query.TupleQueryResultHandler, rx.Producer

Enclosing class:

OnSubscribeTupleResults

public static final class OnSubscribeTupleResults.TupleQueryResultProducer
extends Object
implements rx.Producer, org.openrdf.query.TupleQueryResultHandler

Constructor Summary

Constructors

Constructor and Description
TupleQueryResultProducer(rx.Subscriber<? super org.openrdf.query.BindingSet> o, org.openrdf.query.TupleQuery query)

Method Summary

Modifier and Type	Method and Description
void	endQueryResult()
void	handleBoolean(boolean b)
void	handleLinks(List<String> strings)
void	handleSolution(org.openrdf.query.BindingSet bindings)
void	request(long l)
void	startQueryResult(List<String> strings)

Methods inherited from class java.lang.Object

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

Constructor Detail

TupleQueryResultProducer

public TupleQueryResultProducer(rx.Subscriber<? super org.openrdf.query.BindingSet> o,
                                org.openrdf.query.TupleQuery query)

Method Detail

request

public void request(long l)

Specified by:

request in interface rx.Producer

handleBoolean

public void handleBoolean(boolean b)
                   throws org.openrdf.query.QueryResultHandlerException

Specified by:

handleBoolean in interface org.openrdf.query.QueryResultHandler

Throws:

org.openrdf.query.QueryResultHandlerException

handleLinks

public void handleLinks(List<String> strings)
                 throws org.openrdf.query.QueryResultHandlerException

Specified by:

handleLinks in interface org.openrdf.query.QueryResultHandler

Throws:

org.openrdf.query.QueryResultHandlerException

startQueryResult

public void startQueryResult(List<String> strings)
                      throws org.openrdf.query.TupleQueryResultHandlerException

Specified by:

startQueryResult in interface org.openrdf.query.QueryResultHandler

Throws:

org.openrdf.query.TupleQueryResultHandlerException

endQueryResult

public void endQueryResult()
                    throws org.openrdf.query.TupleQueryResultHandlerException

Specified by:

endQueryResult in interface org.openrdf.query.QueryResultHandler

Throws:

org.openrdf.query.TupleQueryResultHandlerException

handleSolution

public void handleSolution(org.openrdf.query.BindingSet bindings)
                    throws org.openrdf.query.TupleQueryResultHandlerException

Specified by:

handleSolution in interface org.openrdf.query.QueryResultHandler

Throws:

org.openrdf.query.TupleQueryResultHandlerException