IceInternal

Class OutgoingAsyncBase

java.lang.Object

IceInternal.AsyncResultI

IceInternal.OutgoingAsyncBase

All Implemented Interfaces:

AsyncResult

Direct Known Subclasses:

ConnectionFlushBatch, ProxyOutgoingAsyncBase

public abstract class OutgoingAsyncBase
extends AsyncResultI

Field Summary

Fields

Modifier and Type	Field and Description
protected ChildInvocationObserver	_childObserver
protected BasicStream	_os

Fields inherited from class IceInternal.AsyncResultI

_cachedConnection, _instance, _observer, _sentSynchronously, _state, StateCachedBuffers, StateDone, StateEndCalled, StateOK, StateSent

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	OutgoingAsyncBase(Communicator com, Instance instance, java.lang.String op, CallbackBase del)
protected	OutgoingAsyncBase(Communicator com, Instance instance, java.lang.String op, CallbackBase del, BasicStream os)

Method Summary

Modifier and Type	Method and Description
void	attachCollocatedObserver(ObjectAdapter adapter, int requestId)
void	attachRemoteObserver(ConnectionInfo info, Endpoint endpt, int requestId)
boolean	completed(BasicStream is)
boolean	completed(Exception ex)
protected boolean	finished(Exception ex)
BasicStream	getOs()
boolean	sent()
protected boolean	sent(boolean done)

Methods inherited from class IceInternal.AsyncResultI

__wait, cacheMessageBuffers, cancel, cancel, cancelable, check, finished, getCommunicator, getConnection, getObserver, getOperation, getProxy, invokeCompleted, invokeCompletedAsync, invokeSent, invokeSentAsync, isCompleted, isSent, sentSynchronously, throwLocalException, waitForCompleted, waitForSent

Methods inherited from class java.lang.Object

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

Field Detail

_os

protected BasicStream _os

_childObserver

protected ChildInvocationObserver _childObserver

Constructor Detail

OutgoingAsyncBase

protected OutgoingAsyncBase(Communicator com,
                            Instance instance,
                            java.lang.String op,
                            CallbackBase del)

OutgoingAsyncBase

protected OutgoingAsyncBase(Communicator com,
                            Instance instance,
                            java.lang.String op,
                            CallbackBase del,
                            BasicStream os)

Method Detail

sent

public boolean sent()

completed

public boolean completed(BasicStream is)

completed

public boolean completed(Exception ex)

attachRemoteObserver

public final void attachRemoteObserver(ConnectionInfo info,
                                       Endpoint endpt,
                                       int requestId)

attachCollocatedObserver

public final void attachCollocatedObserver(ObjectAdapter adapter,
                                           int requestId)

getOs

public final BasicStream getOs()

sent

protected boolean sent(boolean done)

Overrides:

sent in class AsyncResultI

finished

protected boolean finished(Exception ex)

Overrides:

finished in class AsyncResultI