An interface for a client-side RPC reader. More...
#include <RpcClientReader.hpp>
Public Member Functions | |
| virtual | ~RpcClientReader ()=default |
| Destructor. | |
| virtual bool | read (T &value)=0 |
| Blocking read operation. | |
| virtual bool | read (T &value, const eprosima::fastdds::dds::Duration_t &timeout)=0 |
| Blocking read operation with timeout. | |
| virtual void | cancel ()=0 |
| Cancel the replies feed. | |
An interface for a client-side RPC reader.
Would be used to read replies from a server on an operation with a @feed annotated return type.
|
virtualdefault |
Destructor.
|
pure virtual |
Cancel the replies feed.
Will tell the server to stop sending replies, and block until the server acknowledges the cancellation. The replies feed would then be finished locally, so all pending read operations will return false.
| RpcBrokenPipeException | if the communication with the server breaks. |
|
pure virtual |
Blocking read operation.
Will block until a reply is available or the replies feed has finished.
| value | The value to read the reply into. |
| RpcOperationError | if the server communicates an error. |
| RpcBrokenPipeException | if the communication with the server breaks. |
|
pure virtual |
Blocking read operation with timeout.
Will block until a reply is available, the replies feed has finished, or the timeout expires.
| value | The value to read the reply into. |
| timeout | The maximum time to wait for a reply. |
| RpcOperationError | if the server communicates an error. |
| RpcBrokenPipeException | if the communication with the server breaks. |
| RpcTimeoutException | if the timeout expires. |