de.esoco.coroutine.step.nio

Class ServerSocketAccept.AcceptCallback

java.lang.Object

de.esoco.coroutine.step.nio.ServerSocketAccept.AcceptCallback

All Implemented Interfaces:

java.nio.channels.CompletionHandler<java.nio.channels.AsynchronousSocketChannel,java.lang.Void>

Enclosing class:

ServerSocketAccept

protected static class ServerSocketAccept.AcceptCallback
extends java.lang.Object
implements java.nio.channels.CompletionHandler<java.nio.channels.AsynchronousSocketChannel,java.lang.Void>

A CompletionHandler implementation that receives the result of an asynchronous accept and processes the request with an asynchronous coroutine execution.

Constructor Summary

Constructors

Constructor and Description
AcceptCallback(Coroutine<java.nio.channels.AsynchronousSocketChannel,?> rRequestHandler, Suspension<java.lang.Void> rSuspension) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	completed(java.nio.channels.AsynchronousSocketChannel rRequestChannel, java.lang.Void rIgnored)
void	failed(java.lang.Throwable eError, java.lang.Void rIgnored)

Methods inherited from class java.lang.Object

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

Constructor Detail

AcceptCallback

public AcceptCallback(Coroutine<java.nio.channels.AsynchronousSocketChannel,?> rRequestHandler,
                      Suspension<java.lang.Void> rSuspension)

Creates a new instance.

Parameters:

rRequestHandler - The coroutine to process the request with

rSuspension - The suspension to resume after accepting

Method Detail

completed

public void completed(java.nio.channels.AsynchronousSocketChannel rRequestChannel,
                      java.lang.Void rIgnored)

Specified by:

completed in interface java.nio.channels.CompletionHandler<java.nio.channels.AsynchronousSocketChannel,java.lang.Void>

failed

public void failed(java.lang.Throwable eError,
                   java.lang.Void rIgnored)

Specified by:

failed in interface java.nio.channels.CompletionHandler<java.nio.channels.AsynchronousSocketChannel,java.lang.Void>