Synchronous (blocking) server-side API for doing client-streaming RPCs, where the incoming message stream coming from the client has messages of type R. More...
#include <completion_queue_impl.h>
Public Member Functions | |
| void | SendInitialMetadata () override |
| See the ServerStreamingInterface.SendInitialMetadata method for semantics. More... | |
| bool | NextMessageSize (uint32_t *sz) override |
| Get an upper bound on the next message size available for reading on this stream. More... | |
| bool | Read (R *msg) override |
| Block to read a message and parse to msg. More... | |
 Public Member Functions inherited from grpc_impl::internal::ServerStreamingInterface | |
| virtual | ~ServerStreamingInterface () |
| Public Member Functions inherited from grpc_impl::internal::ReaderInterface< R > | |
| virtual | ~ReaderInterface () |
Friends | |
| template<class ServiceType , class RequestType , class ResponseType > | |
| class | ::grpc_impl::internal::ClientStreamingHandler |
Detailed Description
template<class R>
class grpc_impl::ServerReader< R >
Synchronous (blocking) server-side API for doing client-streaming RPCs, where the incoming message stream coming from the client has messages of type R.
Member Function Documentation
◆ NextMessageSize()
|
inlineoverridevirtual |
Get an upper bound on the next message size available for reading on this stream.
Implements grpc_impl::internal::ReaderInterface< R >.
◆ Read()
|
inlineoverridevirtual |
Block to read a message and parse to msg.
Returns true on success. This is thread-safe with respect to Write or \WritesDone methods on the same stream. It should not be called concurrently with another Read on the same stream as the order of delivery will not be defined.
- Parameters
-
[out] msg The read message.
- Returns
- false when there will be no more incoming messages, either because the other side has called WritesDone() or the stream has failed (or been cancelled).
Implements grpc_impl::internal::ReaderInterface< R >.
◆ SendInitialMetadata()
|
inlineoverridevirtual |
See the ServerStreamingInterface.SendInitialMetadata method for semantics.
Note that initial metadata will be affected by the ServerContext associated with this call.
Implements grpc_impl::internal::ServerStreamingInterface.
Friends And Related Function Documentation
◆ ::grpc_impl::internal::ClientStreamingHandler
|
friend |
The documentation for this class was generated from the following files:
- include/grpcpp/impl/codegen/completion_queue_impl.h
- include/grpcpp/impl/codegen/sync_stream_impl.h
