object ZPipeline extends ZPipelinePlatformSpecificConstructors

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ZPipeline
  2. ZPipelinePlatformSpecificConstructors
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. def apply[In]: ZPipeline[Any, Nothing, In, In]

    A shorter version of ZPipeline.identity, which can facilitate more compact definition of pipelines.

    A shorter version of ZPipeline.identity, which can facilitate more compact definition of pipelines.

    ZPipeline[Int] >>> ZPipeline.filter(_ % 2 != 0)
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def branchAfter[Env, Err, In](n: => Int)(f: (Chunk[In]) => ZPipeline[Env, Err, In, In]): ZPipeline[Env, Err, In, In]
  7. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  8. def collect[In, Out](f: PartialFunction[In, Out]): ZPipeline[Any, Nothing, In, Out]

    Creates a pipeline that collects elements with the specified partial function.

    Creates a pipeline that collects elements with the specified partial function.

    ZPipeline.collect[Option[Int], Int] { case Some(v) => v }
  9. def deflate(bufferSize: => Int = 64 * 1024, noWrap: => Boolean = false, level: => CompressionLevel = CompressionLevel.DefaultCompression, strategy: => CompressionStrategy = CompressionStrategy.DefaultStrategy, flushMode: => FlushMode = FlushMode.NoFlush)(implicit trace: ZTraceElement): ZPipeline[Any, Nothing, Byte, Byte]
  10. def dropUntil[In](f: (In) => Boolean): ZPipeline[Any, Nothing, In, In]

    Creates a pipeline that drops elements until the specified predicate evaluates to true.

    Creates a pipeline that drops elements until the specified predicate evaluates to true.

    ZPipeline.dropUntil[Int](_ > 100)
  11. def dropWhile[In](f: (In) => Boolean): ZPipeline[Any, Nothing, In, In]

    Creates a pipeline that drops elements while the specified predicate evaluates to true.

    Creates a pipeline that drops elements while the specified predicate evaluates to true.

    ZPipeline.dropWhile[Int](_ <= 100)
  12. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  14. def filter[In](f: (In) => Boolean): ZPipeline[Any, Nothing, In, In]

    Creates a pipeline that filters elements according to the specified predicate.

  15. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  16. def fromChannel[Env, Err, In, Out](channel: => ZChannel[Env, Nothing, Chunk[In], Any, Err, Chunk[Out], Any]): ZPipeline[Env, Err, In, Out]

    Creates a pipeline that sends all the elements through the given channel.

  17. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  18. def groupAdjacentBy[In, Key](f: (In) => Key): ZPipeline[Any, Nothing, In, (Key, NonEmptyChunk[In])]

    Creates a pipeline that groups on adjacent keys, calculated by function f.

  19. def gunzip[Env](bufferSize: => Int = 64 * 1024)(implicit trace: ZTraceElement): ZPipeline[Any, CompressionException, Byte, Byte]
  20. def gzip(bufferSize: => Int = 64 * 1024, level: => CompressionLevel = CompressionLevel.DefaultCompression, strategy: => CompressionStrategy = CompressionStrategy.DefaultStrategy, flushMode: => FlushMode = FlushMode.NoFlush)(implicit trace: ZTraceElement): ZPipeline[Any, Nothing, Byte, Byte]
  21. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  22. def identity[In]: ZPipeline[Any, Nothing, In, In]

    The identity pipeline, which does not modify streams in any way.

  23. def inflate(bufferSize: => Int = 64 * 1024, noWrap: => Boolean = false)(implicit trace: ZTraceElement): ZPipeline[Any, CompressionException, Byte, Byte]
  24. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  25. val iso_8859_1Decode: ZPipeline[Any, Nothing, Byte, String]
  26. val iso_8859_1Encode: ZPipeline[Any, Nothing, String, Byte]
  27. def map[In, Out](f: (In) => Out): ZPipeline[Any, Nothing, In, Out]

    Creates a pipeline that maps elements with the specified function.

  28. def mapChunks[In, Out](f: (Chunk[In]) => Chunk[Out]): ZPipeline[Any, Nothing, In, Out]

    Creates a pipeline that maps chunks of elements with the specified function.

  29. def mapChunksZIO[Env, Err, In, Out](f: (Chunk[In]) => ZIO[Env, Err, Chunk[Out]]): ZPipeline[Env, Err, In, Out]

    Creates a pipeline that maps chunks of elements with the specified effect.

  30. def mapZIO[Env, Err, In, Out](f: (In) => ZIO[Env, Err, Out]): ZPipeline[Env, Err, In, Out]

    Creates a pipeline that maps elements with the specified effectful function.

  31. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  32. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  33. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  34. def prepend[In](values: => Chunk[In]): ZPipeline[Any, Nothing, In, In]

    Emits the provided chunk before emitting any other value.

  35. def rechunk[In](n: => Int): ZPipeline[Any, Nothing, In, In]

    A pipeline that rechunks the stream into chunks of the specified size.

  36. def scan[In, Out](s: => Out)(f: (Out, In) => Out): ZPipeline[Any, Nothing, In, Out]

    Creates a pipeline that scans elements with the specified function.

  37. def scanZIO[Env, Err, In, Out](s: => Out)(f: (Out, In) => ZIO[Env, Err, Out]): ZPipeline[Env, Err, In, Out]

    Creates a pipeline that scans elements with the specified function.

  38. val splitLines: ZPipeline[Any, Nothing, String, String]

    Splits strings on newlines.

    Splits strings on newlines. Handles both Windows newlines (\r\n) and UNIX newlines (\n).

  39. def splitOn(delimiter: => String): ZPipeline[Any, Nothing, String, String]

    Splits strings on a delimiter.

  40. def splitOnChunk[In](delimiter: => Chunk[In]): ZPipeline[Any, Nothing, In, In]

    Splits strings on a delimiter.

  41. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  42. def take[In](n: => Long): ZPipeline[Any, Nothing, In, In]

    Creates a pipeline that takes n elements.

  43. def takeUntil[In](f: (In) => Boolean): ZPipeline[Any, Nothing, In, In]

    Creates a pipeline that takes elements until the specified predicate evaluates to true.

  44. def takeWhile[In](f: (In) => Boolean): ZPipeline[Any, Nothing, In, In]

    Creates a pipeline that takes elements while the specified predicate evaluates to true.

  45. def toString(): String
    Definition Classes
    AnyRef → Any
  46. val usASCIIDecode: ZPipeline[Any, Nothing, Byte, String]
  47. val usASCIIEncode: ZPipeline[Any, Nothing, String, Byte]
  48. val utf16BEDecode: ZPipeline[Any, Nothing, Byte, String]
  49. val utf16BEEncode: ZPipeline[Any, Nothing, String, Byte]
  50. val utf16BEWithBomEncode: ZPipeline[Any, Nothing, String, Byte]
  51. val utf16Decode: ZPipeline[Any, Nothing, Byte, String]
  52. val utf16Encode: ZPipeline[Any, Nothing, String, Byte]
  53. val utf16LEDecode: ZPipeline[Any, Nothing, Byte, String]
  54. val utf16LEEncode: ZPipeline[Any, Nothing, String, Byte]
  55. val utf16LEWithBomEncode: ZPipeline[Any, Nothing, String, Byte]
  56. val utf16WithBomEncode: ZPipeline[Any, Nothing, String, Byte]
  57. val utf32BEDecode: ZPipeline[Any, Nothing, Byte, String]
  58. val utf32BEEncode: ZPipeline[Any, Nothing, String, Byte]
  59. val utf32BEWithBomEncode: ZPipeline[Any, Nothing, String, Byte]
  60. val utf32Decode: ZPipeline[Any, Nothing, Byte, String]
  61. val utf32Encode: ZPipeline[Any, Nothing, String, Byte]
  62. val utf32LEDecode: ZPipeline[Any, Nothing, Byte, String]
  63. val utf32LEEncode: ZPipeline[Any, Nothing, String, Byte]
  64. val utf32LEWithBomEncode: ZPipeline[Any, Nothing, String, Byte]
  65. val utf32WithBomEncode: ZPipeline[Any, Nothing, String, Byte]
  66. val utf8Decode: ZPipeline[Any, Nothing, Byte, String]
  67. val utf8Encode: ZPipeline[Any, Nothing, String, Byte]

    utf*Encode pipelines adhere to the same behavior of Java's String#getBytes(charset), that is:

    utf*Encode pipelines adhere to the same behavior of Java's String#getBytes(charset), that is:

    • utf8: No BOM
    • utf16: Has BOM (the outlier)
    • utf16BE & utf16LE: No BOM
    • All utf32 variants: No BOM

    If BOM is required, users can use the *WithBomEncode variants. (As alluded above, utf16Encode always prepends BOM, just like getBytes("UTF-16") in Java. In fact, it is an alias to both utf16BEWithBomEncode and utf16WithBomEncode.

  68. val utf8WithBomEncode: ZPipeline[Any, Nothing, String, Byte]
  69. val utfDecode: ZPipeline[Any, Nothing, Byte, String]

    utfDecode determines the right encoder to use based on the Byte Order Mark (BOM).

    utfDecode determines the right encoder to use based on the Byte Order Mark (BOM). If it doesn't detect one, it defaults to utf8Decode. In the case of utf16 and utf32 without BOM, utf16Decode and utf32Decode should be used instead as both default to their own default decoder respectively.

  70. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  71. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  72. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped