net.sf.asyncobjects
Class AsyncUnicastServer<T extends AsyncObject>

java.lang.Object
  net.sf.asyncobjects.AsyncUnicastServer<T>

Type Parameters:

T - facet type for the object

All Implemented Interfaces:

AsyncObject, ExplicitSharing

Direct Known Subclasses:

BufferedInput, BufferedOutput, CallableAdapter.InternalCallableAdapter, CloseableWrapper, GeneratingInput, InputStreamAdapter, ListenerAdapter.InternalListenerAdapter, MapperAdapter.InternalMapperAdapter, MulticastOutput, NIOServerSocket, NIOSocket, NIOSocketFactory, NIOStream, NulInput, OutputStreamAdapter, Pipe, Pipe.InternalPipeInput, Pipe.InternalPipeOutput, Promise.InternalPromiseResolverImpl, Queue, RecordingOutput, RunnableAdapter.InternalRunnableAdapter, Semaphore, TimerTaskAdapter.InternalTimerTask, TimerWrapper, TServerSocket, TSocket, TSocketFactory, When.InternalArgumentListener, When.InternalBodyPromiseResolver, When.InternalFinallyListenerAfterFault, When.InternalFinallyListenerAfterSuccess, When.InternalResultPromiseResolver, WrappingChannel

public abstract class AsyncUnicastServer<T extends AsyncObject>
extends Object
implements ExplicitSharing, AsyncObject

Unicast server implementation. This is a base class for all servers. The class must support all methods that are declared in the asynchronous interfaces implemented by the this object.

• To support oneway method, the method should implement method that have the same method signature as is declared in the interface.

• To support a request/response method, the method should have method that have the same parameter types as is declared in the interface. The return type must match return type defined in the interface.

  Promise

  In that case result of method invocation will match resolution of promise. The returnin null has the same effect as returning Promise.nullPromise().

  AsyncObject or interfaces that extend it

  In that case result of method invocation will be result of dereferencing this object with method AsyncObject.dereference(AResolver).

  Note if the method throws an exception, it fails with this exception. For a request-response method the returns a Promise, it the same as returning promise created with Promise.smashed(Throwable). For the method that return type that extends AsyncObject interface, result is the same as if the method Promise.willBe(Class) were called on the smashed Promise.

The invocation of the request/response method finishes when one of the following is true:

• If method return an instance of Promise the method finishes when promise is either resolved (in that case it finishes successfully) or smashed (in that case it fails).
• If method return an instance of AsyncObject for which AsyncObject.isImmediate() == false. The method finishes when on resolver passed to AsyncObject.dereference(AResolver) the method AResolver.smash(Throwable) is called (in that case it fails) or the method AResolver.resolve(Object) is called (in that case it finishes successfully) with argument of that method.
• If method return throw exception, it finishes successfully.
• If method returns any other value except listed above, it finishes successfully with returned value.

Constructor Summary

protected

AsyncUnicastServer() A constructor

Method Summary

void	dereference(AResolver<?> r) Implementation of dereference method.
T	export()
boolean	isImmediate()
protected Vat	myVat()
Promise<T>	promise()

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncUnicastServer

protected AsyncUnicastServer()

A constructor

Method Detail

export

public final T export()

Returns:

proxy object that enqueues events for this object

myVat

protected Vat myVat()

Returns:

the vat to which events from this object are dispatched.

promise

public final Promise<T> promise()

Returns:

a promise for exported reference. It is identical to Promise.with(export()).

dereference

public final void dereference(AResolver<?> r)

Implementation of dereference method.

Specified by:

dereference in interface AsyncObject

Parameters:

r - a resolver

See Also:

AsyncObject.dereference(AResolver)

isImmediate

public final boolean isImmediate()

Specified by:

isImmediate in interface AsyncObject

Returns:

true if no dereferencing is required

See Also:

AsyncObject.isImmediate()