Package com.google.cloud.pubsublite.internal.wire

Interface Subscriber

  • All Superinterfaces:
    com.google.api.core.ApiService
    All Known Implementing Classes:
    SubscriberImpl
    public interface Subscriber
extends com.google.api.core.ApiService
    A generic PubSub Lite subscriber. Errors are handled out of band. Messages are sent out of band. Thread safe.

    • Nested Class Summary

      • Nested classes/interfaces inherited from interface com.google.api.core.ApiService

        com.google.api.core.ApiService.Listener, com.google.api.core.ApiService.State

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void allowFlow​(FlowControlRequest request)  

      • Methods inherited from interface com.google.api.core.ApiService

        addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning, startAsync, state, stopAsync