net.sf.asyncobjects.io
Class BufferedTextChannel

java.lang.Object
  net.sf.asyncobjects.AsyncUnicastServer<C>
      net.sf.asyncobjects.io.WrappingChannel<TextData,ATextInput,ATextOutput,ATextChannel>
          net.sf.asyncobjects.io.BufferedTextChannel

All Implemented Interfaces:

ACloseable, AsyncObject, ExplicitSharing, AChannel<TextData,ATextInput,ATextOutput>, ATextChannel

public class BufferedTextChannel
extends WrappingChannel<TextData,ATextInput,ATextOutput,ATextChannel>
implements ATextChannel

Text channel that wraps existing channel and adds buffering functionality over it.

Author:

const

Field Summary

protected int

bufferSize a buffer size

Fields inherited from class net.sf.asyncobjects.io.WrappingChannel

in, out, wrapped

Constructor Summary

BufferedTextChannel(ATextChannel wrapped, int bufferSize)
A constructor

Method Summary

protected ATextInput	wrap(ATextInput input) Wrap input into buffered stream
protected ATextOutput	wrap(ATextOutput output) Wrap output into buffered stream

Methods inherited from class net.sf.asyncobjects.io.WrappingChannel

close, getInput, getOutput

Methods inherited from class net.sf.asyncobjects.AsyncUnicastServer

dereference, export, isImmediate, myVat, promise

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.sf.asyncobjects.io.AChannel

getInput, getOutput

Methods inherited from interface net.sf.asyncobjects.ACloseable

close

Methods inherited from interface net.sf.asyncobjects.AsyncObject

dereference, isImmediate

Field Detail

bufferSize

protected final int bufferSize

a buffer size

Constructor Detail

BufferedTextChannel

public BufferedTextChannel(ATextChannel wrapped,
                           int bufferSize)

A constructor

Parameters:

wrapped - a wrapped channel

bufferSize - a buffer size for streams

Method Detail

wrap

protected ATextInput wrap(ATextInput input)

Wrap input into buffered stream

Specified by:

wrap in class WrappingChannel<TextData,ATextInput,ATextOutput,ATextChannel>

Parameters:

input - an input to wrap

Returns:

a buffered stream

See Also:

WrappingChannel.wrap(net.sf.asyncobjects.io.AInput)

wrap

protected ATextOutput wrap(ATextOutput output)

Wrap output into buffered stream

Specified by:

wrap in class WrappingChannel<TextData,ATextInput,ATextOutput,ATextChannel>

Parameters:

output - an output

Returns:

wrapped stream

See Also:

WrappingChannel.wrap(net.sf.asyncobjects.io.AOutput)