org.jetlang.channels
Class MemoryRequestChannel<R,V>

java.lang.Object
  org.jetlang.channels.MemoryRequestChannel<R,V>

All Implemented Interfaces:

RequestChannel<R,V>

public class MemoryRequestChannel<R,V>
extends java.lang.Object
implements RequestChannel<R,V>

User: mrettig Date: Jan 31, 2009 Time: 10:42:42 AM

Constructor Summary

MemoryRequestChannel()

Method Summary

Disposable	publish(DisposingExecutor target, R request, Callback<V> reply)
Disposable	subscribe(DisposingExecutor fiber, Callback<Request<R,V>> onRequest)
Disposable	subscribe(DisposingExecutor fiber, Callback<Request<R,V>> onRequest, Callback<SessionClosed<R>> onRequestEnd)

Methods inherited from class java.lang.Object

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

Constructor Detail

MemoryRequestChannel

public MemoryRequestChannel()

Method Detail

subscribe

public Disposable subscribe(DisposingExecutor fiber,
                            Callback<Request<R,V>> onRequest)

Specified by:

subscribe in interface RequestChannel<R,V>

subscribe

public Disposable subscribe(DisposingExecutor fiber,
                            Callback<Request<R,V>> onRequest,
                            Callback<SessionClosed<R>> onRequestEnd)

Specified by:

subscribe in interface RequestChannel<R,V>

publish

public Disposable publish(DisposingExecutor target,
                          R request,
                          Callback<V> reply)

Specified by:

publish in interface RequestChannel<R,V>