net.sf.asyncobjects.io.util
Class ExhaustingByteInput

java.lang.Object
  net.sf.asyncobjects.AsyncUnicastServer<FacetType>
      net.sf.asyncobjects.util.CloseableWrapper<I,I>
          net.sf.asyncobjects.io.util.ExhaustingInput<BinaryData,AByteInput>
              net.sf.asyncobjects.io.util.ExhaustingByteInput

All Implemented Interfaces:

ACloseable, AsyncObject, ExplicitSharing, AByteInput, AInput<BinaryData>

public class ExhaustingByteInput
extends ExhaustingInput<BinaryData,AByteInput>
implements AByteInput

Byte version of ExhaustingInput.

Author:

const

Nested Class Summary

Nested classes/interfaces inherited from class net.sf.asyncobjects.util.CloseableWrapper

CloseableWrapper.InvalidatingWhen<I,R>

Field Summary

Fields inherited from class net.sf.asyncobjects.util.CloseableWrapper

closeWrapper, requests, wrapped

Constructor Summary

ExhaustingByteInput(AByteInput stream, boolean closeStream)
A constructor

Method Summary

Methods inherited from class net.sf.asyncobjects.io.util.ExhaustingInput

afterInvalidate, beforeClose, exhausted, isPushbackSupported, pushback, read

Methods inherited from class net.sf.asyncobjects.util.CloseableWrapper

close, closed, ensureOpen, ensureValid, invalidate, isValid

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.AInput

isPushbackSupported, pushback, read

Methods inherited from interface net.sf.asyncobjects.ACloseable

close

Methods inherited from interface net.sf.asyncobjects.AsyncObject

dereference, isImmediate

Constructor Detail

ExhaustingByteInput

public ExhaustingByteInput(AByteInput stream,
                           boolean closeStream)

A constructor

Parameters:

stream - wrapped stream

closeStream - if true stream is closed