workflow-testing-jvm/com.squareup.workflow1.testing/WorkflowTurbine

WorkflowTurbine

class WorkflowTurbine<RenderingT>(val firstRendering: RenderingT, receiveTurbine: ReceiveTurbine<RenderingT>)(source)

Simple wrapper around a ReceiveTurbine of RenderingT to provide convenience helper methods specific to Workflow renderings.

Constructors

WorkflowTurbine

constructor(firstRendering: RenderingT, receiveTurbine: ReceiveTurbine<RenderingT>)

Types

Companion

object Companion

Properties

firstRendering

val firstRendering: RenderingT

The first rendering of the Workflow runtime is made synchronously. This is provided separately if any assertions or operations are needed from it.

Functions

awaitNext

suspend fun <T> awaitNext(precondition: (RenderingT) -> Boolean = { true }, map: (RenderingT) -> T, satisfying: T.() -> Boolean = { true }): T

Suspend waiting for the next rendering which satisfies precondition, can successfully be mapped using map and satisfies the satisfying predicate when called on the T rendering after it has been mapped.

awaitNextRendering

suspend fun awaitNextRendering(): RenderingT

Suspend waiting for the next rendering to be produced by the Workflow runtime. Note this includes the first (synchronously made) rendering.

awaitNextRenderingSatisfying

suspend fun awaitNextRenderingSatisfying(predicate: (RenderingT) -> Boolean): RenderingT

Suspend waiting for the next rendering to be produced by the Workflow runtime that satisfies the predicate.

skipRenderings

suspend fun skipRenderings(count: Int)