net.sf.asyncobjects.asyncscala.stream

FilteredStreamBase

class FilteredStreamBase [T, O] extends ChainedCloseable[AStream[O]] with AStream[T]

Simple abstract base class for the streams

Attributes
abstract
Linear Supertypes
AStream[T], ChainedCloseable[AStream[O]], ACloseable, Asynchronous, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. FilteredStreamBase
  2. AStream
  3. ChainedCloseable
  4. ACloseable
  5. Asynchronous
  6. AnyRef
  7. Any
Visibility
  1. Public
  2. All

Instance Constructors

  1. new FilteredStreamBase (stream: AStream[O])

Abstract Value Members

  1. def get : Promise[Option[T]]

    returns

    next element

    Attributes
    protected abstract

Concrete Value Members

  1. def != (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef

  2. def != (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any

  3. def ## (): Int

    Attributes
    final
    Definition Classes
    AnyRef → Any

  4. def == (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef

  5. def == (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any

  6. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any

  7. def clone (): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()

  8. def close : Promise[Unit]

    The #close() operation should be idempotent.

    The #close() operation should be idempotent. It should be no problem with closing the same object twice. The close operation should cancel the current operation if possible. The close should throw exception only in serious cases (for example in case of data loss, or inconsistent data)

    returns

    a promise that resolves when object finishes closing

    Definition Classes
    ChainedCloseable → ACloseable

  9. def ensureOpen (): Unit

    Check if closing underlying resource has been started.

    Check if closing underlying resource has been started.

    Attributes
    protected
    Definition Classes
    ChainedCloseable

  10. def ensureValid (): Unit

    Check for validity only

    Check for validity only

    Attributes
    protected
    Definition Classes
    ChainedCloseable

  11. def ensureValidAndOpen (): Unit

    Check if the stream is valid (invalidation is preferred over closed

    Check if the stream is valid (invalidation is preferred over closed

    Attributes
    protected
    Definition Classes
    ChainedCloseable

  12. def eq (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef

  13. def equals (arg0: Any): Boolean

    Definition Classes
    AnyRef → Any

  14. def finalize (): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()

  15. def getClass (): java.lang.Class[_]

    Attributes
    final
    Definition Classes
    AnyRef

  16. def hashCode (): Int

    Definition Classes
    AnyRef → Any

  17. def invalidate (throwable: Throwable): Unit

    Invalidate stream

    Invalidate stream

    Attributes
    protected
    Definition Classes
    ChainedCloseable

  18. def isClosed : Boolean

    Check if stream is closed

    Check if stream is closed

    Attributes
    protected
    Definition Classes
    ChainedCloseable

  19. def isInstanceOf [T0] : Boolean

    Attributes
    final
    Definition Classes
    Any

  20. def isValid : Boolean

    Check if the stream is valid

    Check if the stream is valid

    Attributes
    protected
    Definition Classes
    ChainedCloseable

  21. def ne (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef

  22. def next : Promise[Option[T]]

    returns

    a promise for the next element. Note means end of the stream

    Definition Classes
    FilteredStreamBase → AStream

  23. def notify (): Unit

    Attributes
    final
    Definition Classes
    AnyRef

  24. def notifyAll (): Unit

    Attributes
    final
    Definition Classes
    AnyRef

  25. val requests : RequestQueue

    The request queue for the stream (it protects both, next and close)

    The request queue for the stream (it protects both, next and close)

    Attributes
    protected

  26. def startClosing (): Unit

    Start closing underlying resource, if you need to wait for completion, use the method #close

    Start closing underlying resource, if you need to wait for completion, use the method #close

    Attributes
    protected
    Definition Classes
    ChainedCloseable

  27. def synchronized [T0] (arg0: ⇒ T0): T0

    Attributes
    final
    Definition Classes
    AnyRef

  28. def toString (): String

    Definition Classes
    AnyRef → Any

  29. def wait (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

  30. def wait (arg0: Long, arg1: Int): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

  31. def wait (arg0: Long): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

  32. val wrapped : AStream[O]

    Attributes
    protected
    Definition Classes
    ChainedCloseable

Inherited from AStream[T]

Inherited from ChainedCloseable[AStream[O]]

Inherited from ACloseable

Inherited from Asynchronous

Inherited from AnyRef

Inherited from Any