Package com.orientechnologies.orient.server.network.protocol.binary

Class OLiveCommandResultListener

java.lang.Object

com.orientechnologies.orient.server.network.protocol.binary.OAbstractCommandResultListener

com.orientechnologies.orient.server.network.protocol.binary.OLiveCommandResultListener

All Implemented Interfaces:

SimpleValueFetchPlanCommandListener, OCommandResultListener, OLiveResultListener

public class OLiveCommandResultListener
extends OAbstractCommandResultListener
implements OLiveResultListener

Asynchronous command result manager. As soon as a record is returned by the command is sent over the wire.

Author:

Luca Garulli (l.garulli--(at)--orientdb.com)

Field Summary

Fields inherited from class com.orientechnologies.orient.server.network.protocol.binary.OAbstractCommandResultListener

wrappedResultListener

Constructor Summary

Constructors

Constructor	Description
OLiveCommandResultListener(OServer server, OClientConnection connection, OCommandResultListener wrappedResultListener)

Method Summary

Modifier and Type	Method	Description
boolean	isEmpty()
void	linkdedBySimpleValue(ODocument doc)
void	onError(int iLiveToken)
void	onLiveResult(int iToken, ORecordOperation iOp)
void	onUnsubscribe(int iLiveToken)
boolean	result(Object iRecord)	This method is called for each result.
void	writeBytes(DataOutputStream out, byte[] bytes)

Methods inherited from class com.orientechnologies.orient.server.network.protocol.binary.OAbstractCommandResultListener

end, fetchRecord, getResult, setFetchPlan

Methods inherited from class java.lang.Object

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

Constructor Details

OLiveCommandResultListener

public OLiveCommandResultListener(OServer server,
 OClientConnection connection,
 OCommandResultListener wrappedResultListener)

Method Details

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

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in class OAbstractCommandResultListener

onLiveResult

public void onLiveResult(int iToken,
 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

writeBytes

public void writeBytes(DataOutputStream out,
 byte[] bytes)
                throws IOException

Throws:

IOException

linkdedBySimpleValue

public void linkdedBySimpleValue(ODocument doc)

Specified by:

linkdedBySimpleValue in interface SimpleValueFetchPlanCommandListener