cse125g2/docs/MessageStream_8hpp_source.html

#pragma once


#include <SDL3/SDL_stdinc.h>


#include <SDL3_net/SDL_net.h>

#include <cstring>

#include <functional>

#include <vector>


class MessageStream

{


public:

    MessageStream(NET_StreamSocket* sock) : socket(sock) {}


    NET_StreamSocket* socket = nullptr;


    bool send(const void* data, Uint32 size);


    bool poll(const std::function<void(const void* data, Uint32 size)>& callback);


private:

    std::vector<Uint8> recvBuf;

};


MessageStream
Length-prefixed framing layer over a TCP stream socket.
Definition MessageStream.hpp:19

MessageStream::MessageStream
MessageStream(NET_StreamSocket *sock)
Definition MessageStream.hpp:22

MessageStream::poll
bool poll(const std::function< void(const void *data, Uint32 size)> &callback)
Read all available bytes from the socket and invoke the callback once per complete message frame.
Definition MessageStream.cpp:16

MessageStream::socket
NET_StreamSocket * socket
Underlying SDL_net stream socket.
Definition MessageStream.hpp:24

MessageStream::send
bool send(const void *data, Uint32 size)
Send a framed message over the socket.
Definition MessageStream.cpp:6