com.google.cloud.pubsub.spi

Interface PubSubRpc.PullFuture

All Superinterfaces:

Future<com.google.pubsub.v1.PullResponse>

Enclosing interface:

PubSubRpc

public static interface PubSubRpc.PullFuture
extends Future<com.google.pubsub.v1.PullResponse>

A Future implementation for pull RPCs. This class also allows users to register callbacks via #addCallback(PullCallback).

Method Summary

Methods

Modifier and Type	Method and Description
void	addCallback(PubSubRpc.PullCallback callback) Registers a callback to be run on the given executor.

Methods inherited from interface java.util.concurrent.Future

cancel, get, get, isCancelled, isDone

Method Detail

addCallback

void addCallback(PubSubRpc.PullCallback callback)

Registers a callback to be run on the given executor. The listener will run when the pull future completed its computation or, if the computation is already complete, immediately. There is no guaranteed ordering of execution of callbacks.

Registered callbacks are run using the same thread that run the RPC call. Only lightweight callbacks should be registered via this method.