com.amazon.carbonado.capability

Interface RemoteProcedure.Reply<R>

Type Parameters:

R - reply object type

Enclosing interface:

RemoteProcedure<R,D>

public static interface RemoteProcedure.Reply<R>

Reply from remote procedure implementation. To avoid leaking resources, the finish method must always be invoked. If an exception is thrown by a method defined in this interface, resources are automatically released.

Method Summary

Methods

Modifier and Type	Method and Description
void	finish() Finish the reply.
void	flush() Flushes all the data sent so far.
RemoteProcedure.Reply<R>	reset() Reset the internal object stream of the reply, allowing cached objects to get freed.
RemoteProcedure.Reply<R>	send(R data) Send reply data to the caller.
RemoteProcedure.Reply<R>	sendAll(Cursor<? extends R> cursor) Reply with all data from the given cursor to the caller.
RemoteProcedure.Reply<R>	sendAll(java.lang.Iterable<? extends R> iterable) Reply with all data from the given iterable to the caller.

Method Detail

send

RemoteProcedure.Reply<R> send(R data)
                              throws RepositoryException

Send reply data to the caller.

Returns:

this Reply instance

Throws:

java.lang.IllegalStateException - if reply is finished

RepositoryException

sendAll

RemoteProcedure.Reply<R> sendAll(java.lang.Iterable<? extends R> iterable)
                                 throws RepositoryException

Reply with all data from the given iterable to the caller.

Returns:

this Reply instance

Throws:

java.lang.IllegalStateException - if reply is finished

RepositoryException

sendAll

RemoteProcedure.Reply<R> sendAll(Cursor<? extends R> cursor)
                                 throws RepositoryException

Reply with all data from the given cursor to the caller.

Returns:

this Reply instance

Throws:

java.lang.IllegalStateException - if reply is finished

RepositoryException

reset

RemoteProcedure.Reply<R> reset()
                               throws RepositoryException

Reset the internal object stream of the reply, allowing cached objects to get freed.

Returns:

this Reply instance

Throws:

java.lang.IllegalStateException - if reply is finished

RepositoryException

flush

void flush()
           throws RepositoryException

Flushes all the data sent so far. Flush is invoked automatically when reply is finished.

Throws:

RepositoryException

finish

void finish()
            throws RepositoryException

Finish the reply.

Throws:

RepositoryException