Packages

  • package root
    Definition Classes
    root
  • package scales

    Scales Xml provides both a more flexible approach to XML handling and a simplified way of interacting with XML.

    Scales Xml provides both a more flexible approach to XML handling and a simplified way of interacting with XML.

    It fits nicely with the Java APIs you know, TrAX and javax.xml.validation for example, allowing you to run XSLTs and convert to and from Scales XML and other DOMs.

    It also provides a far more XPath like experience than the normal Scala XML, Paths look like XPaths and work like them too (with many of the same functions and axes).

    Definition Classes
    root
  • package utils

    The scales.utils packages provide the basis functionality for scales.xml.

    The scales.utils packages provide the basis functionality for scales.xml.

    The Tree an Path collections that underpin the XML model, as well as the iteratee functionality are located in the relevant sub-packages.

    The package object itself pulls in the main utility functions for tree, path and iteratee handling. Import the scales.utils.ScalesUtils object implicit members to provide the path & and | extension functions, the iteratorEnumerator and the +:+ lazy appender for scalaz.EphemeralStream.

    Definition Classes
    scales
  • package io
    Definition Classes
    utils
  • trait ReadableByteChannelWrapperImplicits extends AnyRef
    Definition Classes
    io
  • AsyncDataChunkerEnumerator

class AsyncDataChunkerEnumerator[T, F[_]] extends EnumeratorT[DataChunk, F]

Creates an Enumerator with a given count for Empty -> Cont applications.

When the count is met it returns the Cont for the next Enumeration step.

Note: Call via eval only.

Linear Supertypes
EnumeratorT[DataChunk, F], AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. AsyncDataChunkerEnumerator
  2. EnumeratorT
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new AsyncDataChunkerEnumerator(chunker: DataChunker[T], contOnCont: Int = 5)(implicit F: Monad[F])

    contOnCont

    INFINITE_RETRIES (-1) for keep on trying, the default is 5 (as exposed by the implicit enumerator readableByteChannelEnumerator)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. def #::(e: DataChunk)(implicit F: Monad[F]): EnumeratorT[DataChunk, F]
    Definition Classes
    EnumeratorT
  4. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  5. def apply[A]: (StepT[DataChunk, F, A]) => IterateeT[DataChunk, F, A]
    Definition Classes
    AsyncDataChunkerEnumerator → EnumeratorT
  6. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  7. def bindM[B, G[_]](f: (DataChunk) => G[EnumeratorT[B, F]])(implicit F: Monad[F], G: Monad[G]): F[G[EnumeratorT[B, F]]]
    Definition Classes
    EnumeratorT
  8. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  9. def collect[B](pf: PartialFunction[DataChunk, B])(implicit monad: Monad[F]): EnumeratorT[B, F]
    Definition Classes
    EnumeratorT
  10. def cross[E2](e2: EnumeratorT[E2, F])(implicit M: Monad[F]): EnumeratorT[(DataChunk, E2), F]
    Definition Classes
    EnumeratorT
  11. def drainTo[M[_]](implicit M: Monad[F], P: PlusEmpty[M], Z: Applicative[M]): F[M[DataChunk]]
    Definition Classes
    EnumeratorT
  12. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  14. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  15. def flatMap[B](f: (DataChunk) => EnumeratorT[B, F])(implicit M1: Monad[F]): EnumeratorT[B, F]
    Definition Classes
    EnumeratorT
  16. def flatten[B](implicit ev: ===[DataChunk, F[B]], F: Monad[F]): EnumeratorT[B, F]
    Definition Classes
    EnumeratorT
  17. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  18. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  19. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  20. def map[B](f: (DataChunk) => B)(implicit ev: Monad[F]): EnumeratorT[B, F]
    Definition Classes
    EnumeratorT
  21. def mapE[I](et: EnumerateeT[DataChunk, I, F])(implicit M: Monad[F]): EnumeratorT[I, F]
    Definition Classes
    EnumeratorT
  22. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  23. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  24. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  25. def reduced[B](b: B)(f: (B, DataChunk) => B)(implicit M: Monad[F]): EnumeratorT[B, F]
    Definition Classes
    EnumeratorT
  26. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  27. def toString(): String
    Definition Classes
    AnyRef → Any
  28. def uniq(implicit ord: Order[DataChunk], M: Monad[F]): EnumeratorT[DataChunk, F]
    Definition Classes
    EnumeratorT
  29. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  30. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  31. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  32. def zipWithIndex(implicit M: Monad[F]): EnumeratorT[(DataChunk, Long), F]
    Definition Classes
    EnumeratorT

Inherited from EnumeratorT[DataChunk, F]

Inherited from AnyRef

Inherited from Any

Ungrouped