Interface StreamingServiceGrpc.AsyncService (0.2.0)

public static interface StreamingServiceGrpc.AsyncService

Streaming service for receiving and sending packets.

Methods

public default void acquireLease(AcquireLeaseRequest request, StreamObserver<Lease> responseObserver)

AcquireLease acquires a lease.

Parameters
Name	Description
`request`	`AcquireLeaseRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Lease>`

public default StreamObserver<ReceiveEventsRequest> receiveEvents(StreamObserver<ReceiveEventsResponse> responseObserver)

Receive events given the stream name.

Parameter
Name	Description
`responseObserver`	`io.grpc.stub.StreamObserver<ReceiveEventsResponse>`

Returns
Type	Description
`io.grpc.stub.StreamObserver<ReceiveEventsRequest>`

public default StreamObserver<ReceivePacketsRequest> receivePackets(StreamObserver<ReceivePacketsResponse> responseObserver)

Receive packets from the series.

Parameter
Name	Description
`responseObserver`	`io.grpc.stub.StreamObserver<ReceivePacketsResponse>`

Returns
Type	Description
`io.grpc.stub.StreamObserver<ReceivePacketsRequest>`

public default void releaseLease(ReleaseLeaseRequest request, StreamObserver<ReleaseLeaseResponse> responseObserver)

RleaseLease releases a lease.

Parameters
Name	Description
`request`	`ReleaseLeaseRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<ReleaseLeaseResponse>`

public default void renewLease(RenewLeaseRequest request, StreamObserver<Lease> responseObserver)

RenewLease renews a lease.

Parameters
Name	Description
`request`	`RenewLeaseRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Lease>`

public default StreamObserver<SendPacketsRequest> sendPackets(StreamObserver<SendPacketsResponse> responseObserver)

Send packets to the series.

Parameter
Name	Description
`responseObserver`	`io.grpc.stub.StreamObserver<SendPacketsResponse>`

Returns
Type	Description
`io.grpc.stub.StreamObserver<SendPacketsRequest>`