public abstract static class PublisherServiceGrpc.PublisherServiceImplBase implements BindableService
The service that a publisher client application uses to publish messages to
topics. Published messages are retained by the service for the duration of
the retention period configured for the respective topic, and are delivered
to subscriber clients upon request (via the SubscriberService).
public StreamObserver<PublishRequest> publish(StreamObserver<PublishResponse> responseObserver)
Establishes a stream with the server for publishing messages. Once the
stream is initialized, the client publishes messages by sending publish
requests on the stream. The server responds with a PublishResponse for each
PublishRequest sent by the client, in the same order that the requests
were sent. Note that multiple PublishRequests can be in flight
simultaneously, but they will be processed by the server in the order that
they are sent by the client on a given stream.
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Hard to understand","hardToUnderstand","thumb-down"],["Incorrect information or sample code","incorrectInformationOrSampleCode","thumb-down"],["Missing the information/samples I need","missingTheInformationSamplesINeed","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2024-11-19 UTC."],[],[]]
