Class faabric::transport::AsyncDirectRecvEndpoint

class AsyncDirectRecvEndpoint : public faabric::transport::RecvMessageEndpoint 

Public Functions

AsyncDirectRecvEndpoint(const std::string &inprocLabel, int timeoutMs = DEFAULT_SOCKET_TIMEOUT_MS)

virtual Message recv() override