akka.stream.scaladsl

Sink

object Sink extends SinkApply

Source
Sink.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Sink
  2. SinkApply
  3. AnyRef
  4. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

    Definition Classes
    AnyRef → Any
  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. def actorRef[T](ref: ActorRef, onCompleteMessage: Any): Sink[T, Unit]

    Sends the elements of the stream to the given ActorRef.

    Sends the elements of the stream to the given ActorRef. If the target actor terminates the stream will be cancelled. When the stream is completed successfully the given onCompleteMessage will be sent to the destination actor. When the stream is completed with failure a akka.actor.Status.Failure message will be sent to the destination actor.

    It will request at most maxInputBufferSize number of elements from upstream, but there is no back-pressure signal from the destination actor, i.e. if the actor is not consuming the messages fast enough the mailbox of the actor will grow. For potentially slow consumer actors it is recommended to use a bounded mailbox with zero mailbox-push-timeout-time or use a rate limiting stage in front of this Sink.

  7. def actorSubscriber[T](props: Props): Sink[T, ActorRef]

    Creates a Sink that is materialized to an akka.actor.ActorRef which points to an Actor created according to the passed in akka.actor.Props.

    Creates a Sink that is materialized to an akka.actor.ActorRef which points to an Actor created according to the passed in akka.actor.Props. Actor created by the props should be akka.stream.actor.ActorSubscriber.

  8. def apply[T](subscriber: Subscriber[T]): Sink[T, Unit]

    Helper to create Sink from Subscriber.

  9. def apply[In, M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12, M13, M14, M15, M16, M17, M18, M19, M20, M21, M22, Mat](g1: Graph[Shape, M1], g2: Graph[Shape, M2], g3: Graph[Shape, M3], g4: Graph[Shape, M4], g5: Graph[Shape, M5], g6: Graph[Shape, M6], g7: Graph[Shape, M7], g8: Graph[Shape, M8], g9: Graph[Shape, M9], g10: Graph[Shape, M10], g11: Graph[Shape, M11], g12: Graph[Shape, M12], g13: Graph[Shape, M13], g14: Graph[Shape, M14], g15: Graph[Shape, M15], g16: Graph[Shape, M16], g17: Graph[Shape, M17], g18: Graph[Shape, M18], g19: Graph[Shape, M19], g20: Graph[Shape, M20], g21: Graph[Shape, M21], g22: Graph[Shape, M22])(combineMat: (M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12, M13, M14, M15, M16, M17, M18, M19, M20, M21, M22) ⇒ Mat)(buildBlock: (Builder[Mat]) ⇒ (Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape) ⇒ Inlet[In]): Sink[In, Mat]

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs.

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs. The create function is expected to return the created Sink's Inlet.

    Definition Classes
    SinkApply
  10. def apply[In, M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12, M13, M14, M15, M16, M17, M18, M19, M20, M21, Mat](g1: Graph[Shape, M1], g2: Graph[Shape, M2], g3: Graph[Shape, M3], g4: Graph[Shape, M4], g5: Graph[Shape, M5], g6: Graph[Shape, M6], g7: Graph[Shape, M7], g8: Graph[Shape, M8], g9: Graph[Shape, M9], g10: Graph[Shape, M10], g11: Graph[Shape, M11], g12: Graph[Shape, M12], g13: Graph[Shape, M13], g14: Graph[Shape, M14], g15: Graph[Shape, M15], g16: Graph[Shape, M16], g17: Graph[Shape, M17], g18: Graph[Shape, M18], g19: Graph[Shape, M19], g20: Graph[Shape, M20], g21: Graph[Shape, M21])(combineMat: (M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12, M13, M14, M15, M16, M17, M18, M19, M20, M21) ⇒ Mat)(buildBlock: (Builder[Mat]) ⇒ (Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape) ⇒ Inlet[In]): Sink[In, Mat]

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs.

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs. The create function is expected to return the created Sink's Inlet.

    Definition Classes
    SinkApply
  11. def apply[In, M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12, M13, M14, M15, M16, M17, M18, M19, M20, Mat](g1: Graph[Shape, M1], g2: Graph[Shape, M2], g3: Graph[Shape, M3], g4: Graph[Shape, M4], g5: Graph[Shape, M5], g6: Graph[Shape, M6], g7: Graph[Shape, M7], g8: Graph[Shape, M8], g9: Graph[Shape, M9], g10: Graph[Shape, M10], g11: Graph[Shape, M11], g12: Graph[Shape, M12], g13: Graph[Shape, M13], g14: Graph[Shape, M14], g15: Graph[Shape, M15], g16: Graph[Shape, M16], g17: Graph[Shape, M17], g18: Graph[Shape, M18], g19: Graph[Shape, M19], g20: Graph[Shape, M20])(combineMat: (M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12, M13, M14, M15, M16, M17, M18, M19, M20) ⇒ Mat)(buildBlock: (Builder[Mat]) ⇒ (Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape) ⇒ Inlet[In]): Sink[In, Mat]

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs.

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs. The create function is expected to return the created Sink's Inlet.

    Definition Classes
    SinkApply
  12. def apply[In, M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12, M13, M14, M15, M16, M17, M18, M19, Mat](g1: Graph[Shape, M1], g2: Graph[Shape, M2], g3: Graph[Shape, M3], g4: Graph[Shape, M4], g5: Graph[Shape, M5], g6: Graph[Shape, M6], g7: Graph[Shape, M7], g8: Graph[Shape, M8], g9: Graph[Shape, M9], g10: Graph[Shape, M10], g11: Graph[Shape, M11], g12: Graph[Shape, M12], g13: Graph[Shape, M13], g14: Graph[Shape, M14], g15: Graph[Shape, M15], g16: Graph[Shape, M16], g17: Graph[Shape, M17], g18: Graph[Shape, M18], g19: Graph[Shape, M19])(combineMat: (M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12, M13, M14, M15, M16, M17, M18, M19) ⇒ Mat)(buildBlock: (Builder[Mat]) ⇒ (Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape) ⇒ Inlet[In]): Sink[In, Mat]

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs.

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs. The create function is expected to return the created Sink's Inlet.

    Definition Classes
    SinkApply
  13. def apply[In, M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12, M13, M14, M15, M16, M17, M18, Mat](g1: Graph[Shape, M1], g2: Graph[Shape, M2], g3: Graph[Shape, M3], g4: Graph[Shape, M4], g5: Graph[Shape, M5], g6: Graph[Shape, M6], g7: Graph[Shape, M7], g8: Graph[Shape, M8], g9: Graph[Shape, M9], g10: Graph[Shape, M10], g11: Graph[Shape, M11], g12: Graph[Shape, M12], g13: Graph[Shape, M13], g14: Graph[Shape, M14], g15: Graph[Shape, M15], g16: Graph[Shape, M16], g17: Graph[Shape, M17], g18: Graph[Shape, M18])(combineMat: (M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12, M13, M14, M15, M16, M17, M18) ⇒ Mat)(buildBlock: (Builder[Mat]) ⇒ (Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape) ⇒ Inlet[In]): Sink[In, Mat]

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs.

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs. The create function is expected to return the created Sink's Inlet.

    Definition Classes
    SinkApply
  14. def apply[In, M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12, M13, M14, M15, M16, M17, Mat](g1: Graph[Shape, M1], g2: Graph[Shape, M2], g3: Graph[Shape, M3], g4: Graph[Shape, M4], g5: Graph[Shape, M5], g6: Graph[Shape, M6], g7: Graph[Shape, M7], g8: Graph[Shape, M8], g9: Graph[Shape, M9], g10: Graph[Shape, M10], g11: Graph[Shape, M11], g12: Graph[Shape, M12], g13: Graph[Shape, M13], g14: Graph[Shape, M14], g15: Graph[Shape, M15], g16: Graph[Shape, M16], g17: Graph[Shape, M17])(combineMat: (M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12, M13, M14, M15, M16, M17) ⇒ Mat)(buildBlock: (Builder[Mat]) ⇒ (Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape) ⇒ Inlet[In]): Sink[In, Mat]

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs.

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs. The create function is expected to return the created Sink's Inlet.

    Definition Classes
    SinkApply
  15. def apply[In, M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12, M13, M14, M15, M16, Mat](g1: Graph[Shape, M1], g2: Graph[Shape, M2], g3: Graph[Shape, M3], g4: Graph[Shape, M4], g5: Graph[Shape, M5], g6: Graph[Shape, M6], g7: Graph[Shape, M7], g8: Graph[Shape, M8], g9: Graph[Shape, M9], g10: Graph[Shape, M10], g11: Graph[Shape, M11], g12: Graph[Shape, M12], g13: Graph[Shape, M13], g14: Graph[Shape, M14], g15: Graph[Shape, M15], g16: Graph[Shape, M16])(combineMat: (M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12, M13, M14, M15, M16) ⇒ Mat)(buildBlock: (Builder[Mat]) ⇒ (Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape) ⇒ Inlet[In]): Sink[In, Mat]

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs.

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs. The create function is expected to return the created Sink's Inlet.

    Definition Classes
    SinkApply
  16. def apply[In, M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12, M13, M14, M15, Mat](g1: Graph[Shape, M1], g2: Graph[Shape, M2], g3: Graph[Shape, M3], g4: Graph[Shape, M4], g5: Graph[Shape, M5], g6: Graph[Shape, M6], g7: Graph[Shape, M7], g8: Graph[Shape, M8], g9: Graph[Shape, M9], g10: Graph[Shape, M10], g11: Graph[Shape, M11], g12: Graph[Shape, M12], g13: Graph[Shape, M13], g14: Graph[Shape, M14], g15: Graph[Shape, M15])(combineMat: (M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12, M13, M14, M15) ⇒ Mat)(buildBlock: (Builder[Mat]) ⇒ (Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape) ⇒ Inlet[In]): Sink[In, Mat]

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs.

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs. The create function is expected to return the created Sink's Inlet.

    Definition Classes
    SinkApply
  17. def apply[In, M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12, M13, M14, Mat](g1: Graph[Shape, M1], g2: Graph[Shape, M2], g3: Graph[Shape, M3], g4: Graph[Shape, M4], g5: Graph[Shape, M5], g6: Graph[Shape, M6], g7: Graph[Shape, M7], g8: Graph[Shape, M8], g9: Graph[Shape, M9], g10: Graph[Shape, M10], g11: Graph[Shape, M11], g12: Graph[Shape, M12], g13: Graph[Shape, M13], g14: Graph[Shape, M14])(combineMat: (M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12, M13, M14) ⇒ Mat)(buildBlock: (Builder[Mat]) ⇒ (Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape) ⇒ Inlet[In]): Sink[In, Mat]

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs.

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs. The create function is expected to return the created Sink's Inlet.

    Definition Classes
    SinkApply
  18. def apply[In, M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12, M13, Mat](g1: Graph[Shape, M1], g2: Graph[Shape, M2], g3: Graph[Shape, M3], g4: Graph[Shape, M4], g5: Graph[Shape, M5], g6: Graph[Shape, M6], g7: Graph[Shape, M7], g8: Graph[Shape, M8], g9: Graph[Shape, M9], g10: Graph[Shape, M10], g11: Graph[Shape, M11], g12: Graph[Shape, M12], g13: Graph[Shape, M13])(combineMat: (M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12, M13) ⇒ Mat)(buildBlock: (Builder[Mat]) ⇒ (Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape) ⇒ Inlet[In]): Sink[In, Mat]

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs.

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs. The create function is expected to return the created Sink's Inlet.

    Definition Classes
    SinkApply
  19. def apply[In, M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12, Mat](g1: Graph[Shape, M1], g2: Graph[Shape, M2], g3: Graph[Shape, M3], g4: Graph[Shape, M4], g5: Graph[Shape, M5], g6: Graph[Shape, M6], g7: Graph[Shape, M7], g8: Graph[Shape, M8], g9: Graph[Shape, M9], g10: Graph[Shape, M10], g11: Graph[Shape, M11], g12: Graph[Shape, M12])(combineMat: (M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12) ⇒ Mat)(buildBlock: (Builder[Mat]) ⇒ (Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape) ⇒ Inlet[In]): Sink[In, Mat]

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs.

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs. The create function is expected to return the created Sink's Inlet.

    Definition Classes
    SinkApply
  20. def apply[In, M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, Mat](g1: Graph[Shape, M1], g2: Graph[Shape, M2], g3: Graph[Shape, M3], g4: Graph[Shape, M4], g5: Graph[Shape, M5], g6: Graph[Shape, M6], g7: Graph[Shape, M7], g8: Graph[Shape, M8], g9: Graph[Shape, M9], g10: Graph[Shape, M10], g11: Graph[Shape, M11])(combineMat: (M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11) ⇒ Mat)(buildBlock: (Builder[Mat]) ⇒ (Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape) ⇒ Inlet[In]): Sink[In, Mat]

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs.

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs. The create function is expected to return the created Sink's Inlet.

    Definition Classes
    SinkApply
  21. def apply[In, M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, Mat](g1: Graph[Shape, M1], g2: Graph[Shape, M2], g3: Graph[Shape, M3], g4: Graph[Shape, M4], g5: Graph[Shape, M5], g6: Graph[Shape, M6], g7: Graph[Shape, M7], g8: Graph[Shape, M8], g9: Graph[Shape, M9], g10: Graph[Shape, M10])(combineMat: (M1, M2, M3, M4, M5, M6, M7, M8, M9, M10) ⇒ Mat)(buildBlock: (Builder[Mat]) ⇒ (Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape) ⇒ Inlet[In]): Sink[In, Mat]

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs.

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs. The create function is expected to return the created Sink's Inlet.

    Definition Classes
    SinkApply
  22. def apply[In, M1, M2, M3, M4, M5, M6, M7, M8, M9, Mat](g1: Graph[Shape, M1], g2: Graph[Shape, M2], g3: Graph[Shape, M3], g4: Graph[Shape, M4], g5: Graph[Shape, M5], g6: Graph[Shape, M6], g7: Graph[Shape, M7], g8: Graph[Shape, M8], g9: Graph[Shape, M9])(combineMat: (M1, M2, M3, M4, M5, M6, M7, M8, M9) ⇒ Mat)(buildBlock: (Builder[Mat]) ⇒ (Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape) ⇒ Inlet[In]): Sink[In, Mat]

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs.

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs. The create function is expected to return the created Sink's Inlet.

    Definition Classes
    SinkApply
  23. def apply[In, M1, M2, M3, M4, M5, M6, M7, M8, Mat](g1: Graph[Shape, M1], g2: Graph[Shape, M2], g3: Graph[Shape, M3], g4: Graph[Shape, M4], g5: Graph[Shape, M5], g6: Graph[Shape, M6], g7: Graph[Shape, M7], g8: Graph[Shape, M8])(combineMat: (M1, M2, M3, M4, M5, M6, M7, M8) ⇒ Mat)(buildBlock: (Builder[Mat]) ⇒ (Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape) ⇒ Inlet[In]): Sink[In, Mat]

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs.

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs. The create function is expected to return the created Sink's Inlet.

    Definition Classes
    SinkApply
  24. def apply[In, M1, M2, M3, M4, M5, M6, M7, Mat](g1: Graph[Shape, M1], g2: Graph[Shape, M2], g3: Graph[Shape, M3], g4: Graph[Shape, M4], g5: Graph[Shape, M5], g6: Graph[Shape, M6], g7: Graph[Shape, M7])(combineMat: (M1, M2, M3, M4, M5, M6, M7) ⇒ Mat)(buildBlock: (Builder[Mat]) ⇒ (Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape) ⇒ Inlet[In]): Sink[In, Mat]

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs.

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs. The create function is expected to return the created Sink's Inlet.

    Definition Classes
    SinkApply
  25. def apply[In, M1, M2, M3, M4, M5, M6, Mat](g1: Graph[Shape, M1], g2: Graph[Shape, M2], g3: Graph[Shape, M3], g4: Graph[Shape, M4], g5: Graph[Shape, M5], g6: Graph[Shape, M6])(combineMat: (M1, M2, M3, M4, M5, M6) ⇒ Mat)(buildBlock: (Builder[Mat]) ⇒ (Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape) ⇒ Inlet[In]): Sink[In, Mat]

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs.

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs. The create function is expected to return the created Sink's Inlet.

    Definition Classes
    SinkApply
  26. def apply[In, M1, M2, M3, M4, M5, Mat](g1: Graph[Shape, M1], g2: Graph[Shape, M2], g3: Graph[Shape, M3], g4: Graph[Shape, M4], g5: Graph[Shape, M5])(combineMat: (M1, M2, M3, M4, M5) ⇒ Mat)(buildBlock: (Builder[Mat]) ⇒ (Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape) ⇒ Inlet[In]): Sink[In, Mat]

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs.

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs. The create function is expected to return the created Sink's Inlet.

    Definition Classes
    SinkApply
  27. def apply[In, M1, M2, M3, M4, Mat](g1: Graph[Shape, M1], g2: Graph[Shape, M2], g3: Graph[Shape, M3], g4: Graph[Shape, M4])(combineMat: (M1, M2, M3, M4) ⇒ Mat)(buildBlock: (Builder[Mat]) ⇒ (Graph.Shape, Graph.Shape, Graph.Shape, Graph.Shape) ⇒ Inlet[In]): Sink[In, Mat]

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs.

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs. The create function is expected to return the created Sink's Inlet.

    Definition Classes
    SinkApply
  28. def apply[In, M1, M2, M3, Mat](g1: Graph[Shape, M1], g2: Graph[Shape, M2], g3: Graph[Shape, M3])(combineMat: (M1, M2, M3) ⇒ Mat)(buildBlock: (Builder[Mat]) ⇒ (Graph.Shape, Graph.Shape, Graph.Shape) ⇒ Inlet[In]): Sink[In, Mat]

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs.

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs. The create function is expected to return the created Sink's Inlet.

    Definition Classes
    SinkApply
  29. def apply[In, M1, M2, Mat](g1: Graph[Shape, M1], g2: Graph[Shape, M2])(combineMat: (M1, M2) ⇒ Mat)(buildBlock: (Builder[Mat]) ⇒ (Graph.Shape, Graph.Shape) ⇒ Inlet[In]): Sink[In, Mat]

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs.

    Creates a Sink by importing the given graphs (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shapes resulting from importing the graphs. The create function is expected to return the created Sink's Inlet.

    Definition Classes
    SinkApply
  30. def apply[In, Mat](g1: Graph[Shape, Mat])(buildBlock: (Builder[Mat]) ⇒ (Graph.Shape) ⇒ Inlet[In]): Sink[In, Mat]

    Creates a Sink by importing the given graph (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shape resulting from importing the graph.

    Creates a Sink by importing the given graph (using builder.graph()) and calling the provided create function with the FlowGraph.Builder[M] and the Shape resulting from importing the graph. The create function is expected to return the created Sink's Inlet.

    Definition Classes
    SinkApply
  31. def apply[In]()(buildBlock: (Builder[Unit]) ⇒ Inlet[In]): Sink[In, Unit]

    Creates a Sink by using a FlowGraph.Builder[Unit] on a block that expects a FlowGraph.Builder and returns an Inlet.

    Creates a Sink by using a FlowGraph.Builder[Unit] on a block that expects a FlowGraph.Builder and returns an Inlet.

    Definition Classes
    SinkApply
  32. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  33. def cancelled[T]: Sink[T, Unit]

    A Sink that immediately cancels its upstream after materialization.

  34. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  35. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  36. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  37. def fanoutPublisher[T](initialBufferSize: Int, maximumBufferSize: Int): Sink[T, Publisher[T]]

    A Sink that materializes into a org.reactivestreams.Publisher that can handle more than one org.reactivestreams.Subscriber.

  38. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  39. def fold[U, T](zero: U)(f: (U, T) ⇒ U): Sink[T, Future[U]]

    A Sink that will invoke the given function for every received element, giving it its previous output (or the given zero value) and the element as input.

    A Sink that will invoke the given function for every received element, giving it its previous output (or the given zero value) and the element as input. The returned scala.concurrent.Future will be completed with value of the final function evaluation when the input stream ends, or completed with Failure if there is a failure signaled in the stream.

  40. def foreach[T](f: (T) ⇒ Unit): Sink[T, Future[Unit]]

    A Sink that will invoke the given procedure for each received element.

    A Sink that will invoke the given procedure for each received element. The sink is materialized into a scala.concurrent.Future will be completed with Success when reaching the normal end of the stream, or completed with Failure if there is a failure signaled in the stream..

  41. def foreachParallel[T](parallelism: Int)(f: (T) ⇒ Unit)(implicit ec: ExecutionContext): Sink[T, Future[Unit]]

    A Sink that will invoke the given function to each of the elements as they pass in.

    A Sink that will invoke the given function to each of the elements as they pass in. The sink is materialized into a scala.concurrent.Future

    If f throws an exception and the supervision decision is akka.stream.Supervision.Stop the Future will be completed with failure.

    If f throws an exception and the supervision decision is akka.stream.Supervision.Resume or akka.stream.Supervision.Restart the element is dropped and the stream continues.

    See also

    #mapAsyncUnordered

  42. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  43. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  44. def head[T]: Sink[T, Future[T]]

    A Sink that materializes into a Future of the first value received.

  45. def ignore: Sink[Any, Future[Unit]]

    A Sink that will consume the stream and discard the elements.

  46. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  47. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  48. final def notify(): Unit

    Definition Classes
    AnyRef
  49. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  50. def onComplete[T](callback: (Try[Unit]) ⇒ Unit): Sink[T, Unit]

    A Sink that when the flow is completed, either through a failure or normal completion, apply the provided function with scala.util.Success or scala.util.Failure.

  51. def publisher[T]: Sink[T, Publisher[T]]

    A Sink that materializes into a org.reactivestreams.Publisher.

    A Sink that materializes into a org.reactivestreams.Publisher. that can handle one org.reactivestreams.Subscriber.

  52. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  53. def toString(): String

    Definition Classes
    AnyRef → Any
  54. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  55. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  56. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  57. def wrap[T, M](g: Graph[SinkShape[T], M]): Sink[T, M]

    A graph with the shape of a sink logically is a sink, this method makes it so also in type.

Inherited from SinkApply

Inherited from AnyRef

Inherited from Any

Ungrouped