-
public final class DarksideStreamerGrpcKt.DarksideStreamerCoroutineStub extends AbstractCoroutineStub<DarksideStreamerGrpcKt.DarksideStreamerCoroutineStub>
A stub for issuing RPCs to a(n) cash.z.wallet.sdk.rpc.DarksideStreamer service as suspending coroutines.
-
-
Constructor Summary
Constructors Constructor Description DarksideStreamerGrpcKt.DarksideStreamerCoroutineStub(Channel channel, CallOptions callOptions)DarksideStreamerGrpcKt.DarksideStreamerCoroutineStub(Channel channel)
-
Method Summary
Modifier and Type Method Description final Service.Emptyreset(Darkside.DarksideMetaState request, Metadata headers)Executes this RPC and returns the response message, suspending until the RPC completes with Status.OK.final Service.EmptystageBlocksStream(Flow<Darkside.DarksideBlock> requests, Metadata headers)Executes this RPC and returns the response message, suspending until the RPC completes with Status.OK.final Service.EmptystageBlocks(Darkside.DarksideBlocksURL request, Metadata headers)Executes this RPC and returns the response message, suspending until the RPC completes with Status.OK.final Service.EmptystageBlocksCreate(Darkside.DarksideEmptyBlocks request, Metadata headers)Executes this RPC and returns the response message, suspending until the RPC completes with Status.OK.final Service.EmptystageTransactionsStream(Flow<Service.RawTransaction> requests, Metadata headers)Executes this RPC and returns the response message, suspending until the RPC completes with Status.OK.final Service.EmptystageTransactions(Darkside.DarksideTransactionsURL request, Metadata headers)Executes this RPC and returns the response message, suspending until the RPC completes with Status.OK.final Service.EmptyapplyStaged(Darkside.DarksideHeight request, Metadata headers)Executes this RPC and returns the response message, suspending until the RPC completes with Status.OK.final Flow<Service.RawTransaction>getIncomingTransactions(Service.Empty request, Metadata headers)Returns a Flow that, when collected, executes this RPC and emits responses from the server as they arrive. final Service.EmptyclearIncomingTransactions(Service.Empty request, Metadata headers)Executes this RPC and returns the response message, suspending until the RPC completes with Status.OK.final Service.EmptyaddAddressUtxo(Service.GetAddressUtxosReply request, Metadata headers)Executes this RPC and returns the response message, suspending until the RPC completes with Status.OK.final Service.EmptyclearAddressUtxo(Service.Empty request, Metadata headers)Executes this RPC and returns the response message, suspending until the RPC completes with Status.OK.final Service.EmptyaddTreeState(Service.TreeState request, Metadata headers)Executes this RPC and returns the response message, suspending until the RPC completes with Status.OK.final Service.EmptyremoveTreeState(Service.BlockID request, Metadata headers)Executes this RPC and returns the response message, suspending until the RPC completes with Status.OK.final Service.EmptyclearAllTreeStates(Service.Empty request, Metadata headers)Executes this RPC and returns the response message, suspending until the RPC completes with Status.OK.-
Methods inherited from class io.grpc.kotlin.AbstractCoroutineStub
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady -
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
-
Method Detail
-
reset
final Service.Empty reset(Darkside.DarksideMetaState request, Metadata headers)
Executes this RPC and returns the response message, suspending until the RPC completes with
Status.OK. If the RPC completes with another status, a corresponding StatusException is thrown. If this coroutine is cancelled, the RPC is also cancelled with the corresponding exception as a cause.- Parameters:
request- The request message to send to the server.headers- Metadata to attach to the request.
-
stageBlocksStream
final Service.Empty stageBlocksStream(Flow<Darkside.DarksideBlock> requests, Metadata headers)
Executes this RPC and returns the response message, suspending until the RPC completes with
Status.OK. If the RPC completes with another status, a corresponding StatusException is thrown. If this coroutine is cancelled, the RPC is also cancelled with the corresponding exception as a cause.This function collects the Flow of requests. If the server terminates the RPC for any reason before collection of requests is complete, the collection of requests will be cancelled. If the collection of requests completes exceptionally for any other reason, the RPC will be cancelled for that reason and this method will throw that exception.
- Parameters:
requests- A Flow of request messages.headers- Metadata to attach to the request.
-
stageBlocks
final Service.Empty stageBlocks(Darkside.DarksideBlocksURL request, Metadata headers)
Executes this RPC and returns the response message, suspending until the RPC completes with
Status.OK. If the RPC completes with another status, a corresponding StatusException is thrown. If this coroutine is cancelled, the RPC is also cancelled with the corresponding exception as a cause.- Parameters:
request- The request message to send to the server.headers- Metadata to attach to the request.
-
stageBlocksCreate
final Service.Empty stageBlocksCreate(Darkside.DarksideEmptyBlocks request, Metadata headers)
Executes this RPC and returns the response message, suspending until the RPC completes with
Status.OK. If the RPC completes with another status, a corresponding StatusException is thrown. If this coroutine is cancelled, the RPC is also cancelled with the corresponding exception as a cause.- Parameters:
request- The request message to send to the server.headers- Metadata to attach to the request.
-
stageTransactionsStream
final Service.Empty stageTransactionsStream(Flow<Service.RawTransaction> requests, Metadata headers)
Executes this RPC and returns the response message, suspending until the RPC completes with
Status.OK. If the RPC completes with another status, a corresponding StatusException is thrown. If this coroutine is cancelled, the RPC is also cancelled with the corresponding exception as a cause.This function collects the Flow of requests. If the server terminates the RPC for any reason before collection of requests is complete, the collection of requests will be cancelled. If the collection of requests completes exceptionally for any other reason, the RPC will be cancelled for that reason and this method will throw that exception.
- Parameters:
requests- A Flow of request messages.headers- Metadata to attach to the request.
-
stageTransactions
final Service.Empty stageTransactions(Darkside.DarksideTransactionsURL request, Metadata headers)
Executes this RPC and returns the response message, suspending until the RPC completes with
Status.OK. If the RPC completes with another status, a corresponding StatusException is thrown. If this coroutine is cancelled, the RPC is also cancelled with the corresponding exception as a cause.- Parameters:
request- The request message to send to the server.headers- Metadata to attach to the request.
-
applyStaged
final Service.Empty applyStaged(Darkside.DarksideHeight request, Metadata headers)
Executes this RPC and returns the response message, suspending until the RPC completes with
Status.OK. If the RPC completes with another status, a corresponding StatusException is thrown. If this coroutine is cancelled, the RPC is also cancelled with the corresponding exception as a cause.- Parameters:
request- The request message to send to the server.headers- Metadata to attach to the request.
-
getIncomingTransactions
final Flow<Service.RawTransaction> getIncomingTransactions(Service.Empty request, Metadata headers)
Returns a Flow that, when collected, executes this RPC and emits responses from the server as they arrive. That flow finishes normally if the server closes its response with
Status.OK, and fails by throwing a StatusException otherwise. If collecting the flow downstream fails exceptionally (including via cancellation), the RPC is cancelled with that exception as a cause.- Parameters:
request- The request message to send to the server.headers- Metadata to attach to the request.
-
clearIncomingTransactions
final Service.Empty clearIncomingTransactions(Service.Empty request, Metadata headers)
Executes this RPC and returns the response message, suspending until the RPC completes with
Status.OK. If the RPC completes with another status, a corresponding StatusException is thrown. If this coroutine is cancelled, the RPC is also cancelled with the corresponding exception as a cause.- Parameters:
request- The request message to send to the server.headers- Metadata to attach to the request.
-
addAddressUtxo
final Service.Empty addAddressUtxo(Service.GetAddressUtxosReply request, Metadata headers)
Executes this RPC and returns the response message, suspending until the RPC completes with
Status.OK. If the RPC completes with another status, a corresponding StatusException is thrown. If this coroutine is cancelled, the RPC is also cancelled with the corresponding exception as a cause.- Parameters:
request- The request message to send to the server.headers- Metadata to attach to the request.
-
clearAddressUtxo
final Service.Empty clearAddressUtxo(Service.Empty request, Metadata headers)
Executes this RPC and returns the response message, suspending until the RPC completes with
Status.OK. If the RPC completes with another status, a corresponding StatusException is thrown. If this coroutine is cancelled, the RPC is also cancelled with the corresponding exception as a cause.- Parameters:
request- The request message to send to the server.headers- Metadata to attach to the request.
-
addTreeState
final Service.Empty addTreeState(Service.TreeState request, Metadata headers)
Executes this RPC and returns the response message, suspending until the RPC completes with
Status.OK. If the RPC completes with another status, a corresponding StatusException is thrown. If this coroutine is cancelled, the RPC is also cancelled with the corresponding exception as a cause.- Parameters:
request- The request message to send to the server.headers- Metadata to attach to the request.
-
removeTreeState
final Service.Empty removeTreeState(Service.BlockID request, Metadata headers)
Executes this RPC and returns the response message, suspending until the RPC completes with
Status.OK. If the RPC completes with another status, a corresponding StatusException is thrown. If this coroutine is cancelled, the RPC is also cancelled with the corresponding exception as a cause.- Parameters:
request- The request message to send to the server.headers- Metadata to attach to the request.
-
clearAllTreeStates
final Service.Empty clearAllTreeStates(Service.Empty request, Metadata headers)
Executes this RPC and returns the response message, suspending until the RPC completes with
Status.OK. If the RPC completes with another status, a corresponding StatusException is thrown. If this coroutine is cancelled, the RPC is also cancelled with the corresponding exception as a cause.- Parameters:
request- The request message to send to the server.headers- Metadata to attach to the request.
-
-
-
-