56 std::unique_ptr<folly::IOBuf>&& buf,
189 transport_->setReplaySafetyCallback(callback);
void setReplaySafetyCallback(folly::AsyncTransport::ReplaySafetyCallback *callback) override
uint32_t getSendTimeout() const override
std::string getApplicationProtocol() const noexceptoverride
void shutdownWriteNow() override
std::unique_ptr< X509, X509Deleter > X509UniquePtr
void attachEventBase(folly::EventBase *eventBase) override
bool error() const override
void setReadCB(folly::AsyncTransportWrapper::ReadCallback *callback) override
constexpr detail::Map< Move > move
bool readable() const override
void writev(folly::AsyncTransportWrapper::WriteCallback *callback, const iovec *vec, size_t bytes, folly::WriteFlags flags=folly::WriteFlags::NONE) override
ReadCallback * getReadCallback() const override
size_t getAppBytesWritten() const override
—— Concurrent Priority Queue Implementation ——
requires E e noexcept(noexcept(s.error(std::move(e))))
void getLocalAddress(folly::SocketAddress *address) const override
const AsyncTransportCertificate * getSelfCertificate() const override
bool isReplaySafe() const override
bool good() const override
~DecoratedAsyncTransportWrapper() override
bool isEorTrackingEnabled() const override
size_t getRawBytesReceived() const override
bool writable() const override
folly::EventBase * getEventBase() const override
void write(folly::AsyncTransportWrapper::WriteCallback *callback, const void *buf, size_t bytes, folly::WriteFlags flags=folly::WriteFlags::NONE) override
void setSendTimeout(uint32_t timeoutInMs) override
bool isDetachable() const override
void closeWithReset() override
std::string getSecurityProtocol() const override
void shutdownWrite() override
void writeChain(folly::AsyncTransportWrapper::WriteCallback *callback, std::unique_ptr< folly::IOBuf > &&buf, folly::WriteFlags flags=folly::WriteFlags::NONE) override
size_t getAppBytesReceived() const override
const AsyncTransportCertificate * getPeerCertificate() const override
DecoratedAsyncTransportWrapper(typename T::UniquePtr transport)
size_t getRawBytesWritten() const override
void detachEventBase() override
folly::ssl::X509UniquePtr getPeerCert() const override
void getPeerAddress(folly::SocketAddress *address) const override
void setEorTracking(bool track) override
bool connecting() const override
const AsyncTransportWrapper * getWrappedTransport() const override