Packages

o

akka.stream.testkit

TestSourceStage

object TestSourceStage

Source
TestGraphStage.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TestSourceStage
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. def apply[T, M](stageUnderTest: GraphStageWithMaterializedValue[SourceShape[T], M], probe: TestProbe): Source[T, M]

    Creates a source out of the stageUnderTest that will inform the probe of operator events and callbacks by sending it the various messages found under GraphStageMessages.

    Creates a source out of the stageUnderTest that will inform the probe of operator events and callbacks by sending it the various messages found under GraphStageMessages.

    This allows for creation of a "normal" stream starting with the source while still being able to assert internal events.