t

streamz.converter

ConverterDsl

trait ConverterDsl extends Converter

Linear Supertypes
Converter, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ConverterDsl
  2. Converter
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. implicit class AkkaFlowDsl[A, B, M] extends AnyRef
  2. implicit class AkkaSinkDsl[A, M] extends AnyRef
  3. implicit class AkkaSinkMatDsl[A, M] extends AnyRef
  4. implicit class AkkaSourceDsl[A, M] extends AnyRef
  5. implicit class FS2PipeIODsl[F[_], A, B] extends AnyRef
  6. implicit class FS2PipePureDsl[A, B] extends AnyRef
  7. implicit class FS2SinkIODsl[F[_], A] extends AnyRef
  8. implicit class FS2SinkPureDsl[A] extends AnyRef
  9. implicit class FS2StreamIODsl[F[_], A] extends AnyRef
  10. implicit class FS2StreamNothingDsl[A] extends AnyRef
  11. implicit class FS2StreamPureDsl[A] extends AnyRef

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 akkaFlowToFs2Pipe[F[_], A, B, M](flow: Graph[FlowShape[A, B], M])(onMaterialization: (M) ⇒ Unit)(implicit arg0: ContextShift[F], materializer: Materializer, F: Concurrent[F]): Pipe[F, A, B]

    Converts an Akka Stream Graph of FlowShape to an FS2 Pipe.

    Converts an Akka Stream Graph of FlowShape to an FS2 Pipe. The Graph is materialized when the Pipe's F in run. The materialized value can be obtained with the onMaterialization callback.

    Definition Classes
    Converter
  5. def akkaSinkToFs2Pipe[F[_], A, M](sink: Graph[SinkShape[A], M])(onMaterialization: (M) ⇒ Unit)(implicit arg0: ContextShift[F], materializer: Materializer, F: Concurrent[F]): Pipe[F, A, Unit]

    Converts an Akka Stream Graph of SinkShape to an FS2 Sink.

    Converts an Akka Stream Graph of SinkShape to an FS2 Sink. The Graph is materialized when the Sink's F in run. The materialized value can be obtained with the onMaterialization callback.

    Definition Classes
    Converter
  6. def akkaSinkToFs2PipeMat[F[_], A, M](akkaSink: Graph[SinkShape[A], Future[M]])(implicit arg0: ConcurrentEffect[F], arg1: ContextShift[F], ec: ExecutionContext, m: Materializer): Pipe[F, A, Either[Throwable, M]]

    Converts an akka sink with a success-status-indicating Future[M] materialized result into an fs2 Pipe which will fail if the Future fails.

    Converts an akka sink with a success-status-indicating Future[M] materialized result into an fs2 Pipe which will fail if the Future fails. The stream returned by this will emit the Future's value one time at the end, then terminate.

    Definition Classes
    Converter
  7. def akkaSourceToFs2Stream[F[_], A, M](source: Graph[SourceShape[A], M])(onMaterialization: (M) ⇒ Unit)(implicit arg0: ContextShift[F], materializer: Materializer, F: Async[F]): Stream[F, A]

    Converts an Akka Stream Graph of SourceShape to an FS2 Stream.

    Converts an Akka Stream Graph of SourceShape to an FS2 Stream. The Graph is materialized when the Stream's F in run. The materialized value can be obtained with the onMaterialization callback.

    Definition Classes
    Converter
  8. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  9. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native() @HotSpotIntrinsicCandidate()
  10. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  11. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  12. def fs2PipeToAkkaFlow[F[_], A, B](pipe: Pipe[F, A, B])(implicit arg0: ContextShift[F], F: ConcurrentEffect[F]): Graph[FlowShape[A, B], NotUsed]

    Converts an FS2 Pipe to an Akka Stream Graph of FlowShape.

    Converts an FS2 Pipe to an Akka Stream Graph of FlowShape. The Pipe is run when the Graph is materialized.

    Definition Classes
    Converter
  13. def fs2PipeToAkkaSink[F[_], A](sink: Pipe[F, A, Unit])(implicit arg0: ContextShift[F], F: Effect[F]): Graph[SinkShape[A], Future[Done]]

    Converts an FS2 Pipe to an Akka Stream Graph of SinkShape.

    Converts an FS2 Pipe to an Akka Stream Graph of SinkShape. The Sink is run when the Graph is materialized.

    Definition Classes
    Converter
  14. def fs2StreamToAkkaSource[F[_], A](stream: Stream[F, A])(implicit arg0: ContextShift[F], F: ConcurrentEffect[F]): Graph[SourceShape[A], NotUsed]

    Converts an FS2 Stream to an Akka Stream Graph of SourceShape.

    Converts an FS2 Stream to an Akka Stream Graph of SourceShape. The Stream is run when the Graph is materialized.

    Definition Classes
    Converter
  15. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  16. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  17. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  18. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  19. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  20. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  21. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  22. def toString(): String
    Definition Classes
    AnyRef → Any
  23. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  24. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  25. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] ) @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

Inherited from Converter

Inherited from AnyRef

Inherited from Any

Ungrouped