net.sf.asyncobjects.io
Class TextPipe

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

All Implemented Interfaces:

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

public class TextPipe
extends Pipe<TextData,ATextInput,ATextOutput,ATextChannel>
implements ATextChannel

A pipe is pair of output stream and input stream, what is written to output stream, could be later read from input stream. The object supports ATextChannel interface. Note that input supports AInput.pushback(BatchedData) operation.

Author:

const

See Also:

ATextChannel

Nested Class Summary

class	TextPipe.InternalTextPipeInput Pipe input
class	TextPipe.InternalTextPipeOutput Pipe output

Nested classes/interfaces inherited from class net.sf.asyncobjects.io.Pipe

Pipe.InternalPipeInput, Pipe.InternalPipeOutput

Constructor Summary

TextPipe(int size)
make a pipe

Method Summary

protected ATextInput	createInput()
protected ATextOutput	createOutput()

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

close, getInput, getOutput, pushback

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

Constructor Detail

TextPipe

public TextPipe(int size)

make a pipe

Parameters:

size - buffer size for pipe

Method Detail

createInput

protected ATextInput createInput()

Specified by:

createInput in class Pipe<TextData,ATextInput,ATextOutput,ATextChannel>

Returns:

an created input

See Also:

Pipe.createInput()

createOutput

protected ATextOutput createOutput()

Specified by:

createOutput in class Pipe<TextData,ATextInput,ATextOutput,ATextChannel>

Returns:

an created output

See Also:

Pipe.createOutput()