stcp.h

Go to the documentation of this file.

 
#ifndef QB_IO_TRANSPORT_STCP_H
#define QB_IO_TRANSPORT_STCP_H
#include <iostream>
#include "../stream.h"
#include "../tcp/ssl/socket.h"
namespace qb::io::transport {

class stcp : public stream<io::tcp::ssl::socket> {
public:
    constexpr bool is_secure() const noexcept { return true; }
    [[nodiscard]] int
    read() noexcept {
        static constexpr const std::size_t bucket_read = 8192;
 
        auto ret = _in.read(_in_buffer.allocate_back(bucket_read), bucket_read);
        if (ret >= 0) {
            _in_buffer.free_back(bucket_read - ret);
            const auto pending = SSL_pending(transport().ssl_handle());
            if (pending) {
                ret += _in.read(_in_buffer.allocate_back(pending), pending);
            }
        }
        return ret;
    }
};
 
} // namespace qb::io::transport
 
#endif // QB_IO_TRANSPORT_STCP_H