java.lang.Object
- com.google.api.core.AbstractApiService
- - com.google.cloud.pubsublite.internal.ProxyService
  - - com.google.cloud.pubsublite.internal.wire.PartitionCountWatchingPublisher

All Implemented Interfaces:: com.google.api.core.ApiService, Publisher<MessageMetadata>, Flushable

public class PartitionCountWatchingPublisher
extends ProxyService
implements Publisher<MessageMetadata>

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

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`cancelOutstandingPublishes()`
`void`	`flush()`
`protected void`	`handlePermanentError(CheckedApiException error)`
`com.google.api.core.ApiFuture<MessageMetadata>`	`publish(PubSubMessage message)`
`protected void`	`stop()`

Methods inherited from class com.google.cloud.pubsublite.internal.ProxyService
addServices, addServices, doStart, doStop, onPermanentError, start

Methods inherited from class com.google.api.core.AbstractApiService
addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync

Methods inherited from interface com.google.api.core.ApiService
addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning, startAsync, state, stopAsync

Class PartitionCountWatchingPublisher