Custom observer that handles all connection events. More...

Inheritance diagram for chat_observer:

Collaboration diagram for chat_observer:

Public Member Functions
	chat_observer (const std::string &name)

auto	on_connected () -> void override
	Called when the connection is established.

auto	on_disconnected (std::optional< std::string_view > reason) -> void override
	Called when the connection is closed.

auto	on_receive (std::span< const uint8_t > data) -> void override
	Called when data is received from the server.

auto	on_error (std::error_code ec) -> void override
	Called when an error occurs.

auto	message_count () const -> int

Public Member Functions inherited from kcenon::network::interfaces::connection_observer
virtual	~connection_observer ()=default

Private Attributes
std::string	name_

int	message_count_ = 0

Detailed Description

Custom observer that handles all connection events.

This demonstrates the recommended pattern for handling client events. All events go through a single object, making it easy to maintain state.

Examples: observer_pattern.cpp.

Definition at line 51 of file observer_pattern.cpp.

Constructor & Destructor Documentation

◆ chat_observer()

chat_observer::chat_observer ( const std::string & name )

inlineexplicit

Examples: observer_pattern.cpp.

Definition at line 53 of file observer_pattern.cpp.

53: name_(name) {}

chat_observer::name_

std::string name_

Definition observer_pattern.cpp:80

Member Function Documentation

◆ message_count()

auto chat_observer::message_count ( ) const -> int

inlinenodiscard

Examples: observer_pattern.cpp.

Definition at line 77 of file observer_pattern.cpp.

77{ return message_count_; }

chat_observer::message_count_

int message_count_

Definition observer_pattern.cpp:81

References message_count_.

◆ on_connected()

auto chat_observer::on_connected ( ) -> void

inlineoverridevirtual

Called when the connection is established.

This is called after a successful connection to the server.

Implements kcenon::network::interfaces::connection_observer.

Examples: observer_pattern.cpp.

Definition at line 55 of file observer_pattern.cpp.

                                         {
        std::cout << "[" << name_ << "] Connected to server." << std::endl;
    }

References name_.

◆ on_disconnected()

auto chat_observer::on_disconnected ( std::optional< std::string_view > reason ) -> void

inlineoverridevirtual

Called when the connection is closed.

Parameters

reason Optional reason for the disconnection.

Note

The reason may be empty for normal disconnections.

Implements kcenon::network::interfaces::connection_observer.

Examples: observer_pattern.cpp.

Definition at line 59 of file observer_pattern.cpp.

                                                                              {
        std::cout << "[" << name_ << "] Disconnected";
        if (reason.has_value()) {
            std::cout << " (reason: " << reason.value() << ")";
        }
        std::cout << std::endl;
    }

References name_.

◆ on_error()

auto chat_observer::on_error ( std::error_code ec ) -> void

inlineoverridevirtual

Called when an error occurs.

Parameters

ec	The error code describing the error.

Implements kcenon::network::interfaces::connection_observer.

Examples: observer_pattern.cpp.

Definition at line 73 of file observer_pattern.cpp.

                                                     {
        std::cerr << "[" << name_ << "] Error: " << ec.message() << std::endl;
    }

References name_.

◆ on_receive()

auto chat_observer::on_receive ( std::span< const uint8_t > data ) -> void

inlineoverridevirtual

Called when data is received from the server.

Parameters

data	The received data as a span of bytes.

Thread Safety

May be called from I/O threads. Implementation must be thread-safe.

Implements kcenon::network::interfaces::connection_observer.

Examples: observer_pattern.cpp.

Definition at line 67 of file observer_pattern.cpp.

                                                                  {
        std::string message(data.begin(), data.end());
        std::cout << "[" << name_ << "] Received: " << message << std::endl;
        ++message_count_;
    }