akka.stream.scaladsl

Source

object Source extends SourceApply

Source
Source.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Source
  2. SourceApply
  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 actorPublisher[T](props: Props): Source[T, ActorRef]

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

    Creates a Source 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.ActorPublisher.

  7. def actorRef[T](bufferSize: Int, overflowStrategy: OverflowStrategy): Source[T, ActorRef]

    Creates a Source that is materialized as an akka.actor.ActorRef.

    Creates a Source that is materialized as an akka.actor.ActorRef. Messages sent to this actor will be emitted to the stream if there is demand from downstream, otherwise they will be buffered until request for demand is received.

    Depending on the defined akka.stream.OverflowStrategy it might drop elements if there is no space available in the buffer.

    The strategy akka.stream.OverflowStrategy.backpressure is not supported, and an IllegalArgument("Backpressure overflowStrategy not supported") will be thrown if it is passed as argument.

    The buffer can be disabled by using bufferSize of 0 and then received messages are dropped if there is no demand from downstream. When bufferSize is 0 the overflowStrategy does not matter.

    The stream can be completed successfully by sending the actor reference an akka.actor.Status.Success message in which case already buffered elements will be signalled before signalling completion, or by sending a akka.actor.PoisonPill in which case completion will be signalled immediately.

    The stream can be completed with failure by sending akka.actor.Status.Failure to the actor reference. In case the Actor is still draining its internal buffer (after having received an akka.actor.Status.Success) before signalling completion and it receives a akka.actor.Status.Failure, the failure will be signalled downstream immediatly (instead of the completion signal).

    The actor will be stopped when the stream is completed, failed or cancelled from downstream, i.e. you can watch it to get notified when that happens.

    bufferSize

    The size of the buffer in element count

    overflowStrategy

    Strategy that is used when incoming elements cannot fit inside the buffer

  8. def apply[T](initialDelay: FiniteDuration, interval: FiniteDuration, tick: T): Source[T, Cancellable]

    Elements are emitted periodically with the specified interval.

    Elements are emitted periodically with the specified interval. The tick element will be delivered to downstream consumers that has requested any elements. If a consumer has not requested any elements at the point in time when the tick element is produced it will not receive that tick element later. It will receive new tick elements as soon as it has requested more elements.

  9. def apply[T](future: Future[T]): Source[T, Unit]

    Start a new Source from the given Future.

    Start a new Source from the given Future. The stream will consist of one element when the Future is completed with a successful value, which may happen before or after materializing the Flow. The stream terminates with a failure if the Future is completed with a failure.

  10. def apply[T](iterable: Iterable[T]): Source[T, Unit]

    Helper to create Source from Iterable.

    Helper to create Source from Iterable. Example usage: Source(Seq(1,2,3))

    Starts a new Source from the given Iterable. This is like starting from an Iterator, but every Subscriber directly attached to the Publisher of this stream will see an individual flow of elements (always starting from the beginning) regardless of when they subscribed.

  11. def apply[T](f: () ⇒ Iterator[T]): Source[T, Unit]

    Helper to create Source from Iterator.

    Helper to create Source from Iterator. Example usage: Source(() => Iterator.from(0))

    Start a new Source from the given function that produces anIterator. The produced stream of elements will continue until the iterator runs empty or fails during evaluation of the next() method. Elements are pulled out of the iterator in accordance with the demand coming from the downstream transformation steps.

  12. def apply[T](publisher: Publisher[T]): Source[T, Unit]

    Helper to create Source from Publisher.

    Helper to create Source from Publisher.

    Construct a transformation starting with given publisher. The transformation steps are executed by a series of org.reactivestreams.Processor instances that mediate the flow of elements downstream and the propagation of back-pressure upstream.

  13. def apply[Out, 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) ⇒ Outlet[Out]): Source[Out, Mat]

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 23 graphs and then returns an Outlet.

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 23 graphs and then returns an Outlet. The graphs will be imported (using Builder.graph()) and the resulting shapes will be passed into the create block.

    Definition Classes
    SourceApply
  14. def apply[Out, 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) ⇒ Outlet[Out]): Source[Out, Mat]

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 22 graphs and then returns an Outlet.

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 22 graphs and then returns an Outlet. The graphs will be imported (using Builder.graph()) and the resulting shapes will be passed into the create block.

    Definition Classes
    SourceApply
  15. def apply[Out, 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) ⇒ Outlet[Out]): Source[Out, Mat]

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 21 graphs and then returns an Outlet.

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 21 graphs and then returns an Outlet. The graphs will be imported (using Builder.graph()) and the resulting shapes will be passed into the create block.

    Definition Classes
    SourceApply
  16. def apply[Out, 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) ⇒ Outlet[Out]): Source[Out, Mat]

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 20 graphs and then returns an Outlet.

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 20 graphs and then returns an Outlet. The graphs will be imported (using Builder.graph()) and the resulting shapes will be passed into the create block.

    Definition Classes
    SourceApply
  17. def apply[Out, 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) ⇒ Outlet[Out]): Source[Out, Mat]

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 19 graphs and then returns an Outlet.

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 19 graphs and then returns an Outlet. The graphs will be imported (using Builder.graph()) and the resulting shapes will be passed into the create block.

    Definition Classes
    SourceApply
  18. def apply[Out, 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) ⇒ Outlet[Out]): Source[Out, Mat]

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 18 graphs and then returns an Outlet.

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 18 graphs and then returns an Outlet. The graphs will be imported (using Builder.graph()) and the resulting shapes will be passed into the create block.

    Definition Classes
    SourceApply
  19. def apply[Out, 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) ⇒ Outlet[Out]): Source[Out, Mat]

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 17 graphs and then returns an Outlet.

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 17 graphs and then returns an Outlet. The graphs will be imported (using Builder.graph()) and the resulting shapes will be passed into the create block.

    Definition Classes
    SourceApply
  20. def apply[Out, 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) ⇒ Outlet[Out]): Source[Out, Mat]

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 16 graphs and then returns an Outlet.

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 16 graphs and then returns an Outlet. The graphs will be imported (using Builder.graph()) and the resulting shapes will be passed into the create block.

    Definition Classes
    SourceApply
  21. def apply[Out, 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) ⇒ Outlet[Out]): Source[Out, Mat]

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 15 graphs and then returns an Outlet.

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 15 graphs and then returns an Outlet. The graphs will be imported (using Builder.graph()) and the resulting shapes will be passed into the create block.

    Definition Classes
    SourceApply
  22. def apply[Out, 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) ⇒ Outlet[Out]): Source[Out, Mat]

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 14 graphs and then returns an Outlet.

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 14 graphs and then returns an Outlet. The graphs will be imported (using Builder.graph()) and the resulting shapes will be passed into the create block.

    Definition Classes
    SourceApply
  23. def apply[Out, 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) ⇒ Outlet[Out]): Source[Out, Mat]

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 13 graphs and then returns an Outlet.

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 13 graphs and then returns an Outlet. The graphs will be imported (using Builder.graph()) and the resulting shapes will be passed into the create block.

    Definition Classes
    SourceApply
  24. def apply[Out, 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) ⇒ Outlet[Out]): Source[Out, Mat]

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 12 graphs and then returns an Outlet.

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 12 graphs and then returns an Outlet. The graphs will be imported (using Builder.graph()) and the resulting shapes will be passed into the create block.

    Definition Classes
    SourceApply
  25. def apply[Out, 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) ⇒ Outlet[Out]): Source[Out, Mat]

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 11 graphs and then returns an Outlet.

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 11 graphs and then returns an Outlet. The graphs will be imported (using Builder.graph()) and the resulting shapes will be passed into the create block.

    Definition Classes
    SourceApply
  26. def apply[Out, 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) ⇒ Outlet[Out]): Source[Out, Mat]

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 10 graphs and then returns an Outlet.

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 10 graphs and then returns an Outlet. The graphs will be imported (using Builder.graph()) and the resulting shapes will be passed into the create block.

    Definition Classes
    SourceApply
  27. def apply[Out, 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) ⇒ Outlet[Out]): Source[Out, Mat]

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 9 graphs and then returns an Outlet.

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 9 graphs and then returns an Outlet. The graphs will be imported (using Builder.graph()) and the resulting shapes will be passed into the create block.

    Definition Classes
    SourceApply
  28. def apply[Out, 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) ⇒ Outlet[Out]): Source[Out, Mat]

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 8 graphs and then returns an Outlet.

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 8 graphs and then returns an Outlet. The graphs will be imported (using Builder.graph()) and the resulting shapes will be passed into the create block.

    Definition Classes
    SourceApply
  29. def apply[Out, 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) ⇒ Outlet[Out]): Source[Out, Mat]

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 7 graphs and then returns an Outlet.

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 7 graphs and then returns an Outlet. The graphs will be imported (using Builder.graph()) and the resulting shapes will be passed into the create block.

    Definition Classes
    SourceApply
  30. def apply[Out, 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) ⇒ Outlet[Out]): Source[Out, Mat]

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 6 graphs and then returns an Outlet.

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 6 graphs and then returns an Outlet. The graphs will be imported (using Builder.graph()) and the resulting shapes will be passed into the create block.

    Definition Classes
    SourceApply
  31. def apply[Out, 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) ⇒ Outlet[Out]): Source[Out, Mat]

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 5 graphs and then returns an Outlet.

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 5 graphs and then returns an Outlet. The graphs will be imported (using Builder.graph()) and the resulting shapes will be passed into the create block.

    Definition Classes
    SourceApply
  32. def apply[Out, 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) ⇒ Outlet[Out]): Source[Out, Mat]

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 4 graphs and then returns an Outlet.

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 4 graphs and then returns an Outlet. The graphs will be imported (using Builder.graph()) and the resulting shapes will be passed into the create block.

    Definition Classes
    SourceApply
  33. def apply[Out, M1, M2, Mat](g1: Graph[Shape, M1], g2: Graph[Shape, M2])(combineMat: (M1, M2) ⇒ Mat)(buildBlock: (Builder[Mat]) ⇒ (Graph.Shape, Graph.Shape) ⇒ Outlet[Out]): Source[Out, Mat]

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 3 graphs and then returns an Outlet.

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 3 graphs and then returns an Outlet. The graphs will be imported (using Builder.graph()) and the resulting shapes will be passed into the create block.

    Definition Classes
    SourceApply
  34. def apply[Out, Mat](g1: Graph[Shape, Mat])(buildBlock: (Builder[Mat]) ⇒ (Graph.Shape) ⇒ Outlet[Out]): Source[Out, Mat]

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 1 graph and then returns an Outlet.

    Creates a Source by using a FlowGraph.Builder[M] on a block that expects a FlowGraph.Builder and 1 graph and then returns an Outlet. The graph will be imported (using Builder.graph()) and the resulting shape will be passed into the create block.

    Definition Classes
    SourceApply
  35. def apply[Out]()(buildBlock: (Builder[Unit]) ⇒ Outlet[Out]): Source[Out, Unit]

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

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

    Definition Classes
    SourceApply
  36. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  37. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  38. def concat[T, Mat1, Mat2](source1: Graph[SourceShape[T], Mat1], source2: Graph[SourceShape[T], Mat2]): Source[T, (Mat1, Mat2)]

    Concatenates two sources so that the first element emitted by the second source is emitted after the last element of the first source.

  39. def concatMat[T, Mat1, Mat2, Mat3](source1: Graph[SourceShape[T], Mat1], source2: Graph[SourceShape[T], Mat2])(combine: (Mat1, Mat2) ⇒ Mat3): Source[T, Mat3]

    Concatenates two sources so that the first element emitted by the second source is emitted after the last element of the first source.

  40. def empty[T]: Source[T, Unit]

    A Source with no elements, i.

    A Source with no elements, i.e. an empty stream that is completed immediately for every connected Sink.

  41. final def eq(arg0: AnyRef): Boolean

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

    Definition Classes
    AnyRef → Any
  43. def failed[T](cause: Throwable): Source[T, Unit]

    Create a Source that immediately ends the stream with the cause error to every connected Sink.

  44. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  45. final def getClass(): Class[_]

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

    Definition Classes
    AnyRef → Any
  47. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  48. def lazyEmpty[T]: Source[T, Promise[Unit]]

    Create a Source with no elements, which does not complete its downstream, until externally triggered to do so.

    Create a Source with no elements, which does not complete its downstream, until externally triggered to do so.

    It materializes a scala.concurrent.Promise which will be completed when the downstream stage of this source cancels. This promise can also be used to externally trigger completion, which the source then signalls to its downstream.

  49. final def ne(arg0: AnyRef): Boolean

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

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

    Definition Classes
    AnyRef
  52. def repeat[T](element: T): Source[T, Unit]

    Create a Source that will continually emit the given element.

  53. def single[T](element: T): Source[T, Unit]

    Create a Source with one element.

    Create a Source with one element. Every connected Sink of this stream will see an individual stream consisting of one element.

  54. def subscriber[T]: Source[T, Subscriber[T]]

    Creates a Source that is materialized as a org.reactivestreams.Subscriber

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

    Definition Classes
    AnyRef
  56. def toString(): String

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

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

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

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  60. def wrap[T, M](g: Graph[SourceShape[T], M]): Source[T, M]

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

Inherited from SourceApply

Inherited from AnyRef

Inherited from Any

Ungrouped