Class faabric::transport::SyncRecvMessageEndpoint

class SyncRecvMessageEndpoint : public faabric::transport::RecvMessageEndpoint

Public Functions

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

SyncRecvMessageEndpoint(int portIn, int timeoutMs = DEFAULT_SOCKET_TIMEOUT_MS)

virtual Message recv() override

void sendResponse(uint8_t header, const uint8_t *data, size_t dataSize)