docs/net.corda.testing.flows

Package-level declarations

Functions

Link copied to clipboard
infix fun <T : Class<out Any>> T.from(session: <Error class: unknown class>): <Error class: unknown class><<Error class: unknown class>, T>

Creates a [Pair(session, Class)] from this Class.

infix fun <R : Any> Map<<Error class: unknown class>, <Error class: unknown class><Any>>.from(session: <Error class: unknown class>): R

Extracts data from a [MapFlowSession, UntrustworthyData] without performing checks and casting to R.

infix fun <T : Any> KClass<T>.from(session: <Error class: unknown class>): <Error class: unknown class><<Error class: unknown class>, Class<T>>

Creates a [Pair(session, Class)] from this KClass.

Link copied to clipboard
inline fun <R : Any> <Error class: unknown class><out <Error class: unknown class>>.receiveAll(session: <Error class: unknown class>, vararg sessions: <Error class: unknown class>): List<<Error class: unknown class><R>>
fun <Error class: unknown class><out <Error class: unknown class>>.receiveAll(session: <Error class: unknown class><<Error class: unknown class>, Class<out Any>>, vararg sessions: <Error class: unknown class><<Error class: unknown class>, Class<out Any>>): Map<<Error class: unknown class>, <Error class: unknown class><Any>>
fun <R : Any> <Error class: unknown class><out <Error class: unknown class>>.receiveAll(receiveType: Class<R>, session: <Error class: unknown class>, vararg sessions: <Error class: unknown class>): List<<Error class: unknown class><R>>

Suspends until a message has been received for each session in the specified sessions.

Link copied to clipboard
inline fun <P> TestStartedNode.registerCordappFlowFactory(initiatingFlowClass: KClass<out <Error class: unknown class><out <Error class: unknown class>>>, initiatedFlowVersion: Int = 1, noinline flowFactory: (<Error class: unknown class>) -> P): <Error class: unknown class><P>
Link copied to clipboard
fun <T> TestStartedNode.registerCoreFlowFactory(initiatingFlowClass: Class<out <Error class: unknown class><out <Error class: unknown class>>>, initiatedFlowClass: Class<T>, flowFactory: (<Error class: unknown class>) -> T, track: Boolean): <Error class: unknown class><T>
Link copied to clipboard
fun waitForAllFlowsToComplete(nodeHandle: NodeHandle, maxIterations: Int = 60, iterationDelay: Long = 500)