infix fun <T : Class<out Any>> T.from(session: FlowSession): <ERROR CLASS><FlowSession, T>
|
|
fun FlowLogic<*>.receiveAll(session: <ERROR CLASS><FlowSession, Class<out Any>>, vararg sessions: <ERROR CLASS><FlowSession, Class<out Any>>): Map<FlowSession, UntrustworthyData<Any>> fun <R : Any> FlowLogic<*>.receiveAll(receiveType: Class<R>, session: FlowSession, vararg sessions: FlowSession): List<UntrustworthyData<R>> fun <R : Any> FlowLogic<*>.receiveAll(session: FlowSession, vararg sessions: FlowSession): List<UntrustworthyData<R>>
Suspends until a message has been received for each session in the specified sessions. |
|
fun <P : FlowLogic<*>> TestStartedNode.registerCordappFlowFactory(initiatingFlowClass: KClass<out FlowLogic<*>>, initiatedFlowVersion: Int = 1, flowFactory: (FlowSession) -> P): CordaFuture<P> |
|
fun <T : FlowLogic<*>> TestStartedNode.registerCoreFlowFactory(initiatingFlowClass: Class<out FlowLogic<*>>, initiatedFlowClass: Class<T>, flowFactory: (FlowSession) -> T, track: Boolean): <ERROR CLASS><T> |