-
public final class CompactTxStreamerGrpcKt.CompactTxStreamerCoroutineStub extends AbstractCoroutineStub<CompactTxStreamerGrpcKt.CompactTxStreamerCoroutineStub>
A stub for issuing RPCs to a(n) cash.z.wallet.sdk.rpc.CompactTxStreamer service as suspending coroutines.
-
-
Constructor Summary
Constructors Constructor Description CompactTxStreamerGrpcKt.CompactTxStreamerCoroutineStub(Channel channel, CallOptions callOptions)CompactTxStreamerGrpcKt.CompactTxStreamerCoroutineStub(Channel channel)
-
Method Summary
Modifier and Type Method Description final Service.BlockIDgetLatestBlock(Service.ChainSpec request, Metadata headers)Executes this RPC and returns the response message, suspending until the RPC completes with Status.OK.final CompactFormats.CompactBlockgetBlock(Service.BlockID request, Metadata headers)Executes this RPC and returns the response message, suspending until the RPC completes with Status.OK.final CompactFormats.CompactBlockgetBlockNullifiers(Service.BlockID request, Metadata headers)Executes this RPC and returns the response message, suspending until the RPC completes with Status.OK.final Flow<CompactFormats.CompactBlock>getBlockRange(Service.BlockRange request, Metadata headers)Returns a Flow that, when collected, executes this RPC and emits responses from the server as they arrive. final Flow<CompactFormats.CompactBlock>getBlockRangeNullifiers(Service.BlockRange request, Metadata headers)Returns a Flow that, when collected, executes this RPC and emits responses from the server as they arrive. final Service.RawTransactiongetTransaction(Service.TxFilter request, Metadata headers)Executes this RPC and returns the response message, suspending until the RPC completes with Status.OK.final Service.SendResponsesendTransaction(Service.RawTransaction request, Metadata headers)Executes this RPC and returns the response message, suspending until the RPC completes with Status.OK.final Flow<Service.RawTransaction>getTaddressTxids(Service.TransparentAddressBlockFilter request, Metadata headers)Returns a Flow that, when collected, executes this RPC and emits responses from the server as they arrive. final Service.BalancegetTaddressBalance(Service.AddressList request, Metadata headers)Executes this RPC and returns the response message, suspending until the RPC completes with Status.OK.final Service.BalancegetTaddressBalanceStream(Flow<Service.Address> requests, Metadata headers)Executes this RPC and returns the response message, suspending until the RPC completes with Status.OK.final Flow<CompactFormats.CompactTx>getMempoolTx(Service.Exclude request, Metadata headers)Returns a Flow that, when collected, executes this RPC and emits responses from the server as they arrive. final Flow<Service.RawTransaction>getMempoolStream(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.TreeStategetTreeState(Service.BlockID request, Metadata headers)Executes this RPC and returns the response message, suspending until the RPC completes with Status.OK.final Service.TreeStategetLatestTreeState(Service.Empty request, Metadata headers)Executes this RPC and returns the response message, suspending until the RPC completes with Status.OK.final Flow<Service.SubtreeRoot>getSubtreeRoots(Service.GetSubtreeRootsArg request, Metadata headers)Returns a Flow that, when collected, executes this RPC and emits responses from the server as they arrive. final Service.GetAddressUtxosReplyListgetAddressUtxos(Service.GetAddressUtxosArg request, Metadata headers)Executes this RPC and returns the response message, suspending until the RPC completes with Status.OK.final Flow<Service.GetAddressUtxosReply>getAddressUtxosStream(Service.GetAddressUtxosArg request, Metadata headers)Returns a Flow that, when collected, executes this RPC and emits responses from the server as they arrive. final Service.LightdInfogetLightdInfo(Service.Empty request, Metadata headers)Executes this RPC and returns the response message, suspending until the RPC completes with Status.OK.final Service.PingResponseping(Service.Duration 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
-
getLatestBlock
final Service.BlockID getLatestBlock(Service.ChainSpec 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.
-
getBlock
final CompactFormats.CompactBlock getBlock(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.
-
getBlockNullifiers
final CompactFormats.CompactBlock getBlockNullifiers(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.
-
getBlockRange
final Flow<CompactFormats.CompactBlock> getBlockRange(Service.BlockRange 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.
-
getBlockRangeNullifiers
final Flow<CompactFormats.CompactBlock> getBlockRangeNullifiers(Service.BlockRange 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.
-
getTransaction
final Service.RawTransaction getTransaction(Service.TxFilter 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.
-
sendTransaction
final Service.SendResponse sendTransaction(Service.RawTransaction 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.
-
getTaddressTxids
final Flow<Service.RawTransaction> getTaddressTxids(Service.TransparentAddressBlockFilter 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.
-
getTaddressBalance
final Service.Balance getTaddressBalance(Service.AddressList 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.
-
getTaddressBalanceStream
final Service.Balance getTaddressBalanceStream(Flow<Service.Address> 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.
-
getMempoolTx
final Flow<CompactFormats.CompactTx> getMempoolTx(Service.Exclude 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.
-
getMempoolStream
final Flow<Service.RawTransaction> getMempoolStream(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.
-
getTreeState
final Service.TreeState getTreeState(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.
-
getLatestTreeState
final Service.TreeState getLatestTreeState(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.
-
getSubtreeRoots
final Flow<Service.SubtreeRoot> getSubtreeRoots(Service.GetSubtreeRootsArg 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.
-
getAddressUtxos
final Service.GetAddressUtxosReplyList getAddressUtxos(Service.GetAddressUtxosArg 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.
-
getAddressUtxosStream
final Flow<Service.GetAddressUtxosReply> getAddressUtxosStream(Service.GetAddressUtxosArg 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.
-
getLightdInfo
final Service.LightdInfo getLightdInfo(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.
-
ping
final Service.PingResponse ping(Service.Duration 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.
-
-
-
-