ai.grakn.grpc

Class TxGrpcCommunicator

java.lang.Object

ai.grakn.grpc.TxGrpcCommunicator

All Implemented Interfaces:

AutoCloseable

public class TxGrpcCommunicator
extends Object
implements AutoCloseable

Wrapper for making Tx calls to a gRPC server - handles sending a stream of GrpcGrakn.TxRequests and receiving a stream of GrpcGrakn.TxResponses. A request is sent with the #send(TxRequest)} method, and you can block for a response with the receive() method.

 

     try (TxGrpcCommunicator tx = TxGrpcCommunicator.create(stub) {
         tx.send(openMessage);
         TxResponse doneMessage = tx.receive().ok();
         tx.send(commitMessage);
         StatusRuntimeException validationError = tx.receive.error();
     }
 
 

Author:

Felix Chapman

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TxGrpcCommunicator.Response A response from the gRPC server, that may be a successful response #ok(TxResponse), an error {@link #error(StatusRuntimeException)} or a "completed" message TxGrpcCommunicator.Response.completed().

Method Summary

Modifier and Type	Method and Description
void	close()
static TxGrpcCommunicator	create(GraknGrpc.GraknStub stub)
boolean	isClosed()
TxGrpcCommunicator.Response	receive() Block until a response is returned.
void	send(GrpcGrakn.TxRequest request) Send a request and return immediately.

Methods inherited from class java.lang.Object

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

Method Detail

create

public static TxGrpcCommunicator create(GraknGrpc.GraknStub stub)

send

public void send(GrpcGrakn.TxRequest request)

Send a request and return immediately. This method is non-blocking - it returns immediately.

receive

public TxGrpcCommunicator.Response receive()
                                    throws InterruptedException

Block until a response is returned.

Throws:

InterruptedException

close

public void close()

Specified by:

close in interface AutoCloseable

isClosed

public boolean isClosed()