de.esoco.coroutine.step.nio

Class AsynchronousChannelStep.ChannelCallback<V,C extends java.nio.channels.AsynchronousChannel>

java.lang.Object

de.esoco.coroutine.step.nio.AsynchronousChannelStep.ChannelCallback<V,C>

All Implemented Interfaces:

java.nio.channels.CompletionHandler<V,java.nio.ByteBuffer>

Enclosing class:

AsynchronousChannelStep<I,O>

protected static class AsynchronousChannelStep.ChannelCallback<V,C extends java.nio.channels.AsynchronousChannel>
extends java.lang.Object
implements java.nio.channels.CompletionHandler<V,java.nio.ByteBuffer>

A CompletionHandler implementation that performs an asynchronous channel operation and resumes a coroutine step afterwards (asynchronously).

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ChannelCallback(C rChannel, Suspension<java.nio.ByteBuffer> rSuspension, AsynchronousChannelStep.ChannelOperation<C> fOperation) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	completed(V rResult, java.nio.ByteBuffer rData)
void	failed(java.lang.Throwable eError, java.nio.ByteBuffer rData)

Methods inherited from class java.lang.Object

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

Constructor Detail

ChannelCallback

protected ChannelCallback(C rChannel,
                          Suspension<java.nio.ByteBuffer> rSuspension,
                          AsynchronousChannelStep.ChannelOperation<C> fOperation)

Creates a new instance.

Parameters:

rChannel - The channel to operate on

rSuspension - The suspension to be resumed when the operation is completed

fOperation - The asychronous channel operation to perform

Method Detail

completed

public void completed(V rResult,
                      java.nio.ByteBuffer rData)

Specified by:

completed in interface java.nio.channels.CompletionHandler<V,java.nio.ByteBuffer>

failed

public void failed(java.lang.Throwable eError,
                   java.nio.ByteBuffer rData)

Specified by:

failed in interface java.nio.channels.CompletionHandler<V,java.nio.ByteBuffer>