Async API on the client side for doing client-streaming RPCs, where the outgoing message stream going to the server contains messages of type W.
More...
#include <async_stream.h>
template<class W>
class grpc::ClientAsyncWriter< W >
Async API on the client side for doing client-streaming RPCs, where the outgoing message stream going to the server contains messages of type W.
◆ Finish()
See the ClientAsyncStreamingInterface.Finish method for semantics.
Side effect:
- the ClientContext associated with this call is updated with possible initial and trailing metadata received from the server.
- attempts to fill in the response parameter passed to this class's constructor with the server's response message.
Implements grpc::internal::ClientAsyncStreamingInterface.
◆ operator delete() [1/2]
◆ operator delete() [2/2]
◆ ReadInitialMetadata()
◆ StartCall()
◆ Write() [1/2]
Request the writing of msg using WriteOptions options with identifying tag tag.
Only one write may be outstanding at any given time. This means that after calling Write, one must wait to receive tag from the completion queue BEFORE calling Write again. WriteOptions options is used to set the write options of this message. This is thread-safe with respect to AsyncReaderInterface::Read
gRPC doesn't take ownership or a reference to msg, so it is safe to to deallocate once Write returns.
- Parameters
-
[in] | msg | The message to be written. |
[in] | options | The WriteOptions to be used to write this message. |
[in] | tag | The tag identifying the operation. |
Implements grpc::internal::AsyncWriterInterface< W >.
◆ Write() [2/2]
Request the writing of msg with identifying tag tag.
Only one write may be outstanding at any given time. This means that after calling Write, one must wait to receive tag from the completion queue BEFORE calling Write again. This is thread-safe with respect to AsyncReaderInterface::Read
gRPC doesn't take ownership or a reference to msg, so it is safe to to deallocate once Write returns.
- Parameters
-
[in] | msg | The message to be written. |
[in] | tag | The tag identifying the operation. |
Implements grpc::internal::AsyncWriterInterface< W >.
◆ WritesDone()
Signal the client is done with the writes (half-close the client stream).
Thread-safe with respect to AsyncReaderInterface::Read
- Parameters
-
[in] | tag | The tag identifying the operation. |
Implements grpc::ClientAsyncWriterInterface< W >.
◆ internal::ClientAsyncWriterFactory< W >
The documentation for this class was generated from the following file: