org.lightningj.lnd.stateservice.proto

Class StateGrpc.StateStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractAsyncStub<StateGrpc.StateStub>

org.lightningj.lnd.stateservice.proto.StateGrpc.StateStub

Enclosing class:

StateGrpc

public static final class StateGrpc.StateStub
extends io.grpc.stub.AbstractAsyncStub<StateGrpc.StateStub>

A stub to allow clients to do asynchronous rpc calls to service State.

 State service is a always running service that exposes the current state of
 the wallet and RPC server.
 

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

Modifier and Type	Method and Description
protected StateGrpc.StateStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
void	getState(Stateservice.GetStateRequest request, io.grpc.stub.StreamObserver<Stateservice.GetStateResponse> responseObserver) GetState returns the current wallet state without streaming further changes.
void	subscribeState(Stateservice.SubscribeStateRequest request, io.grpc.stub.StreamObserver<Stateservice.SubscribeStateResponse> responseObserver) SubscribeState subscribes to the state of the wallet.

Methods inherited from class io.grpc.stub.AbstractAsyncStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReady

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

build

protected StateGrpc.StateStub build(io.grpc.Channel channel,
                                    io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<StateGrpc.StateStub>

subscribeState

public void subscribeState(Stateservice.SubscribeStateRequest request,
                           io.grpc.stub.StreamObserver<Stateservice.SubscribeStateResponse> responseObserver)

 SubscribeState subscribes to the state of the wallet. The current wallet
 state will always be delivered immediately.
 

getState

public void getState(Stateservice.GetStateRequest request,
                     io.grpc.stub.StreamObserver<Stateservice.GetStateResponse> responseObserver)

 GetState returns the current wallet state without streaming further
 changes.