Package | Description |
---|---|
com.google.cloud.pubsub.v1 |
A client to Cloud Pub/Sub API
|
com.google.cloud.pubsub.v1.stub | |
com.google.pubsub.v1 |
Modifier and Type | Method and Description |
---|---|
com.google.api.gax.rpc.BidiStreamingCallable<StreamingPullRequest,StreamingPullResponse> |
SubscriptionAdminClient.streamingPullCallable()
Establishes a stream with the server, which sends messages down to the client.
|
com.google.api.gax.rpc.StreamingCallSettings<StreamingPullRequest,StreamingPullResponse> |
SubscriptionAdminSettings.streamingPullSettings()
Returns the object with the settings used for calls to streamingPull.
|
com.google.api.gax.rpc.StreamingCallSettings.Builder<StreamingPullRequest,StreamingPullResponse> |
SubscriptionAdminSettings.Builder.streamingPullSettings()
Returns the builder for the settings used for calls to streamingPull.
|
Modifier and Type | Method and Description |
---|---|
com.google.api.gax.rpc.BidiStreamingCallable<StreamingPullRequest,StreamingPullResponse> |
SubscriberStub.streamingPullCallable() |
com.google.api.gax.rpc.BidiStreamingCallable<StreamingPullRequest,StreamingPullResponse> |
GrpcSubscriberStub.streamingPullCallable() |
com.google.api.gax.rpc.BidiStreamingCallable<StreamingPullRequest,StreamingPullResponse> |
HttpJsonSubscriberStub.streamingPullCallable() |
com.google.api.gax.rpc.StreamingCallSettings<StreamingPullRequest,StreamingPullResponse> |
SubscriberStubSettings.streamingPullSettings()
Returns the object with the settings used for calls to streamingPull.
|
com.google.api.gax.rpc.StreamingCallSettings.Builder<StreamingPullRequest,StreamingPullResponse> |
SubscriberStubSettings.Builder.streamingPullSettings()
Returns the builder for the settings used for calls to streamingPull.
|
Modifier and Type | Method and Description |
---|---|
StreamingPullResponse |
StreamingPullResponse.Builder.build() |
StreamingPullResponse |
StreamingPullResponse.Builder.buildPartial() |
static StreamingPullResponse |
StreamingPullResponse.getDefaultInstance() |
StreamingPullResponse |
StreamingPullResponse.getDefaultInstanceForType() |
StreamingPullResponse |
StreamingPullResponse.Builder.getDefaultInstanceForType() |
static StreamingPullResponse |
StreamingPullResponse.parseDelimitedFrom(InputStream input) |
static StreamingPullResponse |
StreamingPullResponse.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StreamingPullResponse |
StreamingPullResponse.parseFrom(byte[] data) |
static StreamingPullResponse |
StreamingPullResponse.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StreamingPullResponse |
StreamingPullResponse.parseFrom(ByteBuffer data) |
static StreamingPullResponse |
StreamingPullResponse.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StreamingPullResponse |
StreamingPullResponse.parseFrom(com.google.protobuf.ByteString data) |
static StreamingPullResponse |
StreamingPullResponse.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StreamingPullResponse |
StreamingPullResponse.parseFrom(com.google.protobuf.CodedInputStream input) |
static StreamingPullResponse |
StreamingPullResponse.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StreamingPullResponse |
StreamingPullResponse.parseFrom(InputStream input) |
static StreamingPullResponse |
StreamingPullResponse.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<StreamingPullResponse> |
StreamingPullResponse.getParserForType() |
static MethodDescriptor<StreamingPullRequest,StreamingPullResponse> |
SubscriberGrpc.getStreamingPullMethod() |
static com.google.protobuf.Parser<StreamingPullResponse> |
StreamingPullResponse.parser() |
Modifier and Type | Method and Description |
---|---|
StreamingPullResponse.Builder |
StreamingPullResponse.Builder.mergeFrom(StreamingPullResponse other) |
static StreamingPullResponse.Builder |
StreamingPullResponse.newBuilder(StreamingPullResponse prototype) |
Modifier and Type | Method and Description |
---|---|
default StreamObserver<StreamingPullRequest> |
SubscriberGrpc.AsyncService.streamingPull(StreamObserver<StreamingPullResponse> responseObserver)
Establishes a stream with the server, which sends messages down to the
client.
|
StreamObserver<StreamingPullRequest> |
SubscriberGrpc.SubscriberStub.streamingPull(StreamObserver<StreamingPullResponse> responseObserver)
Establishes a stream with the server, which sends messages down to the
client.
|
Copyright © 2023 Google LLC. All rights reserved.