trait Converter extends AnyRef
- Alphabetic
- By Inheritance
- Converter
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
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. -
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. -
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.
-
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. -
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native() @HotSpotIntrinsicCandidate()
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
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.
-
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.
-
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.
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
Deprecated Value Members
-
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.