Method receive

implementation/endpoints/src/tcp_client_endpoint_impl.cpp:256–264

}

void tcp_client_endpoint_impl::receive() {
    message_buffer_ptr_t its_recv_buffer;
    {
        std::scoped_lock its_lock{socket_mutex_};
        its_recv_buffer = recv_buffer_;
    }
    auto self = std::dynamic_pointer_cast<tcp_client_endpoint_impl>(shared_from_this());
    boost::asio::dispatch(strand_, [self, its_recv_buffer]() { self->receive(its_recv_buffer, 0, 0); });
}

void tcp_client_endpoint_impl::receive(message_buffer_ptr_t _recv_buffer, std::size_t _recv_buffer_size, std::size_t _missing_capacity) {
    std::unique_lock its_lock{socket_mutex_};