Introduction

This library provides advanced asynchronous I/O and networking capabilities using coroutine-based APIs and poller-driven execution. It supports high-performance operations for both network sockets and file handles.

Key Features

The library’s core functionality is exposed through a few high-level classes:

TSocket and TPollerDrivenSocket for asynchronous networking.
TFileHandle and TPollerDrivenFileHandle for asynchronous file I/O.
TLineReader for efficient, line-based input.
TByteReader and TByteWriter for byte-level I/O.
TResolver and TResolvConf for DNS resolution.

In addition to these, the library supports multiple polling mechanisms for asynchronous operations:

TSelect - Poller using the select() system call.
TPoll - Poller using the poll() system call.
TEPoll - Linux-specific poller using epoll.
TKqueue - Poller for macOS/FreeBSD using kqueue.
TIOCp - Poller for Windows using IOCP.
TUring - Linux-specific poller using io_uring.

Example: Echo Client

The following example demonstrates a simple echo client. The client reads lines from standard input, sends them to an echo server, and then prints the response.

template<bool debug, typename TPoller>
TFuture<void> client(TPoller& poller, TAddress addr)
{
    static constexpr int maxLineSize = 4096;
    using TSocket = typename TPoller::TSocket;
    using TFileHandle = typename TPoller::TFileHandle;
    std::vector<char> in(maxLineSize);
 
    try {
        TFileHandle input{0, poller}; // stdin
        TSocket socket{poller, addr.Domain()};
        TLineReader lineReader(input, maxLineSize);
        TByteWriter byteWriter(socket);
        TByteReader byteReader(socket);
 
        co_await socket.Connect(addr, TClock::now() + std::chrono::milliseconds(1000));
        while (auto line = co_await lineReader.Read()) {
            co_await byteWriter.Write(line);
            co_await byteReader.Read(in.data(), line.Size());
            if constexpr (debug) {
                std::cout << "Received: " << std::string_view(in.data(), line.Size()) << "\n";
            }
        }
    } catch (const std::exception& ex) {
        std::cout << "Exception: " << ex.what() << "\n";
    }
 
    co_return;
}

Further Information

For more details on each component, please refer to the following classes:

TSocket and TPollerDrivenSocket
TFileHandle and TPollerDrivenFileHandle
TLineReader, TByteReader, and TByteWriter
TResolver and TResolvConf

For the available pollers, see: