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 |
---|---|
StreamingPullRequest |
StreamingPullRequest.Builder.build() |
StreamingPullRequest |
StreamingPullRequest.Builder.buildPartial() |
static StreamingPullRequest |
StreamingPullRequest.getDefaultInstance() |
StreamingPullRequest |
StreamingPullRequest.getDefaultInstanceForType() |
StreamingPullRequest |
StreamingPullRequest.Builder.getDefaultInstanceForType() |
static StreamingPullRequest |
StreamingPullRequest.parseDelimitedFrom(InputStream input) |
static StreamingPullRequest |
StreamingPullRequest.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StreamingPullRequest |
StreamingPullRequest.parseFrom(byte[] data) |
static StreamingPullRequest |
StreamingPullRequest.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StreamingPullRequest |
StreamingPullRequest.parseFrom(ByteBuffer data) |
static StreamingPullRequest |
StreamingPullRequest.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StreamingPullRequest |
StreamingPullRequest.parseFrom(com.google.protobuf.ByteString data) |
static StreamingPullRequest |
StreamingPullRequest.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StreamingPullRequest |
StreamingPullRequest.parseFrom(com.google.protobuf.CodedInputStream input) |
static StreamingPullRequest |
StreamingPullRequest.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StreamingPullRequest |
StreamingPullRequest.parseFrom(InputStream input) |
static StreamingPullRequest |
StreamingPullRequest.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<StreamingPullRequest> |
StreamingPullRequest.getParserForType() |
static MethodDescriptor<StreamingPullRequest,StreamingPullResponse> |
SubscriberGrpc.getStreamingPullMethod() |
static com.google.protobuf.Parser<StreamingPullRequest> |
StreamingPullRequest.parser() |
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.
|
Modifier and Type | Method and Description |
---|---|
StreamingPullRequest.Builder |
StreamingPullRequest.Builder.mergeFrom(StreamingPullRequest other) |
static StreamingPullRequest.Builder |
StreamingPullRequest.newBuilder(StreamingPullRequest prototype) |
Copyright © 2023 Google LLC. All rights reserved.