pyrasun.eio.protocols.object
Class EIOObjectEndpoint

java.lang.Object
  pyrasun.eio.Endpoint
      pyrasun.eio.ReadWriteEndpoint
          pyrasun.eio.protocols.object.EIOObjectEndpoint

public class EIOObjectEndpoint

extends ReadWriteEndpoint

Central part of the Object protocol, encapsulates non-blocking reading and writing.

Constructor Summary

EIOObjectEndpoint(EndpointCoordinator coordinator, java.nio.channels.SocketChannel nioChannel)

Method Summary

void	writeNext(java.lang.Object nextVictim)

Methods inherited from class pyrasun.eio.ReadWriteEndpoint

abortWrites, addToProcessing, arePendingWrites, getInputBuffer, getNIOChannel, getOutputBuffer, getProcessingQueueDepth, getWriteQueueDepth, isWriteInProgress, isWriteQueueEmpty, needsReadPause, nextForProcessing, nextForWriting, noReadsForMe, noWritesForMe, processingDispatch, readPause, setIsWriteInProgress, write

Methods inherited from class pyrasun.eio.Endpoint

addInterest, addProcessing, attach, attachment, close, close, close, close, close, configureBlocking, dumpProcessedStats, getContext, getCoordinator, getInterestEvents, getNIOInterestEvents, getProcessingEvents, getReadyEvents, getState, isAborted, isBlocking, isLockedForProcessing, isLockedReady, isOpen, isReady, isSelectorized, lockForEventManager, lockForProcessing, lockForReady, masksAsString, registerEventListener, removeInterest, removeProcessing, removeReadiness, reportReadError, reportWriteError, setName, setReadiness, setReadiness, toString, unlockProcessing, updateProcessedStats

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

EIOObjectEndpoint

public EIOObjectEndpoint(EndpointCoordinator coordinator,
                         java.nio.channels.SocketChannel nioChannel)

Method Detail

writeNext

public void writeNext(java.lang.Object nextVictim)
               throws java.io.IOException

Throws:

java.io.IOException