o

akka.stream.testkit

TestSinkStage

object TestSinkStage

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

Value Members

  1. def apply[T, M](stageUnderTest: [SinkShape[T], M], probe: TestProbe): Sink[T, M]

    Creates a sink 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 sink 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 ending with the sink while still being able to assert internal events.