Packages

abstract class AsyncParser extends CloseOnNeed with DocLike

An AynscParser, a DataChunk is fed in via nextInput which, in turn, returns an Input[EphmeralStream[PullType]] of events. When the Input is El then the stream may be evaluated to get all available events, and will return empty when no more for that data chunk is available.

See nextInput for more info.

Linear Supertypes
DocLike, CloseOnNeed, IsClosed, AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. AsyncParser
  2. DocLike
  3. CloseOnNeed
  4. IsClosed
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new AsyncParser()(implicit xmlVersion: XmlVersion)

Type Members

  1. abstract type Token <: OptimisationToken
    Attributes
    protected

Abstract Value Members

  1. abstract val feeder: AsyncByteArrayFeeder
    Attributes
    protected
  2. abstract val parser: AsyncXMLStreamReader[AsyncByteArrayFeeder]
    Attributes
    protected
  3. abstract val strategy: MemoryOptimisationStrategy[Token]
    Attributes
    protected
  4. abstract val token: Token
    Attributes
    protected

Concrete Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. def ++(close2: CloseOnNeed): CloseOnNeed
    Definition Classes
    CloseOnNeed
  4. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  5. def addEndMisc(m: xml.PullType): Unit
    Attributes
    protected
  6. def addPrologMisc(m: xml.PullType): Unit
    Attributes
    protected
  7. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  8. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  9. def closeResource: Unit
    Definition Classes
    CloseOnNeed
  10. def copyProlog(p: Prolog): Unit
    Attributes
    protected
  11. var depth: Int
    Attributes
    protected
  12. def doClose: Unit

    Closes the feeder and parser

    Closes the feeder and parser

    Attributes
    protected
    Definition Classes
    AsyncParser → CloseOnNeed
  13. def end: EndMisc
    Definition Classes
    AsyncParser → DocLike
  14. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  15. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  16. val eventHandler: (Either[Int, Throwable]) ⇒ xml.PullType
    Attributes
    protected
  17. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  18. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  19. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  20. val incompOrEnd: xml.PullType
    Attributes
    protected
  21. def isClosed: Boolean
    Definition Classes
    CloseOnNeed → IsClosed
  22. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  23. def iteratee[F[_]](implicit arg0: Monad[F]): ResumableIter[DataChunk, F, EphemeralStream[xml.PullType]]

    Provides a ResumableIter that converts DataChunks via a parser into a stream of PullTypes.

    Provides a ResumableIter that converts DataChunks via a parser into a stream of PullTypes. Returns Done when there are results from the pushed chunks.

    Calls AsyncParser parse

  24. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  25. def nextInput(d: DataChunk): Input[EphemeralStream[xml.PullType]]

    Given a DataChunk will return the next available data stream.

    Given a DataChunk will return the next available data stream. Returns EOF when the Parser is closed, Empty when more DataChunks are needed. Returning El[EphemeralStream[PullType]] provides a stream which will lazily evalulate all available Xml Events from this DataChunk.

    NOTEs (see Aalto-xml feeder.feedInput for details on this): 1) All existing events from the last El should be consumed before calling nextInput again 2) The DataChunk passed in should not be re-used until the stream returns empty (or Empty/EOF is returned).

  26. def nextStream(): EphemeralStream[xml.PullType]
    Attributes
    protected
  27. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  28. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  29. def prolog: Prolog
    Definition Classes
    AsyncParser → DocLike
  30. def pump(): Input[xml.PullType]
    Attributes
    protected
  31. def pumpMisc(): Input[xml.PullType]

    Pushes through Misc items in either prolog or the epilog

    Pushes through Misc items in either prolog or the epilog

    Attributes
    protected
  32. var started: Boolean
    Attributes
    protected
  33. def startedElementProcessing: Boolean

    The document element has been reached

  34. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  35. def toString(): String
    Definition Classes
    AnyRef → Any
  36. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  37. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  38. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()

Inherited from DocLike

Inherited from CloseOnNeed

Inherited from IsClosed

Inherited from AnyRef

Inherited from Any

Ungrouped