corda / net.corda.core.flows / DataVendingFlow

DataVendingFlow

open class DataVendingFlow : FlowLogic<Void?>

Constructors

<init>

DataVendingFlow(otherSideSession: FlowSession, payload: Any)

Properties

otherSideSession

val otherSideSession: FlowSession

payload

val payload: Any

Functions

call

This is where you fill out your business logic.

open fun call(): Void?

sendPayloadAndReceiveDataRequest

open fun sendPayloadAndReceiveDataRequest(otherSideSession: FlowSession, payload: Any): UntrustworthyData<Request>

verifyDataRequest

open fun verifyDataRequest(dataRequest: Data): Unit

Extension Functions

receiveAll

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

fun FlowLogic<*>.receiveAll(session: Pair<FlowSession, Class<out Any>>, vararg sessions: Pair<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>>

Inheritors

SendStateAndRefFlow

The SendStateAndRefFlow should be used to send a list of input StateAndRef to another peer that wishes to verify the input's integrity by resolving and checking the dependencies as well. The other side should invoke ReceiveStateAndRefFlow at the right point in the conversation to receive the input state and ref and perform the resolution back-and-forth required to check the dependencies.

open class SendStateAndRefFlow : DataVendingFlow

SendTransactionFlow

The SendTransactionFlow should be used to send a transaction to another peer that wishes to verify that transaction's integrity by resolving and checking the dependencies as well. The other side should invoke ReceiveTransactionFlow at the right point in the conversation to receive the sent transaction and perform the resolution back-and-forth required to check the dependencies and download any missing attachments.

open class SendTransactionFlow : DataVendingFlow