docs/net.corda.testing.flows

Package-level declarations

Functions

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

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

infix fun <R : Any> Map<FlowSession, UntrustworthyData<Any>>.from(session: FlowSession): R

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

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

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

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

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

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