com.orientechnologies.orient.core.sql.query

Class OLocalLiveResultListener

java.lang.Object

com.orientechnologies.orient.core.sql.query.OLocalLiveResultListener

All Implemented Interfaces:

OCommandResultListener, OLiveResultListener

public class OLocalLiveResultListener
extends Object
implements OLiveResultListener, OCommandResultListener

Created by luigidellaquila on 23/03/15.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	OLocalLiveResultListener(OLiveResultListener underlying)

Method Summary

Modifier and Type	Method and Description
void	end() Called at the end of processing.
Object	getResult()
void	onError(int iLiveToken)
void	onLiveResult(int iLiveToken, ORecordOperation iOp)
void	onUnsubscribe(int iLiveToken)
boolean	result(Object iRecord) This method is called for each result.

Methods inherited from class java.lang.Object

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

Constructor Detail

OLocalLiveResultListener

protected OLocalLiveResultListener(OLiveResultListener underlying)

Method Detail

result

public boolean result(Object iRecord)

Description copied from interface: OCommandResultListener

This method is called for each result.

Specified by:

result in interface OCommandResultListener

Parameters:

iRecord - Current record

Returns:

True to continue the query, otherwise false

end

public void end()

Description copied from interface: OCommandResultListener

Called at the end of processing. This is useful to clean-up local attributes.

Specified by:

end in interface OCommandResultListener

getResult

public Object getResult()

Specified by:

getResult in interface OCommandResultListener

onLiveResult

public void onLiveResult(int iLiveToken,
                         ORecordOperation iOp)
                  throws OException

Specified by:

onLiveResult in interface OLiveResultListener

Throws:

OException

onError

public void onError(int iLiveToken)

Specified by:

onError in interface OLiveResultListener

onUnsubscribe

public void onUnsubscribe(int iLiveToken)

Specified by:

onUnsubscribe in interface OLiveResultListener