net.sf.asyncobjects.io
Class TextPipe

java.lang.Object
  extended by net.sf.asyncobjects.AsyncUnicastServer<C>
      extended by net.sf.asyncobjects.io.Pipe<TextData,ATextInput,ATextOutput,ATextChannel>
          extended by 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()


Copyright 2002-2007 Constantine Plotnikov. All Rights Reserved.