kitetorrent-session/io.github.yuroyami.kitetorrent.session.net/NetworkRuntime

NetworkRuntime

class NetworkRuntime(context: CoroutineContext)

The socket runtime. One SelectorManager drives all non-blocking I/O, the way a single Boost.Asio io_context does in libtorrent. ktor-network's selector is coroutine-native, so there are no callbacks: a read simply suspends.

Constructors

NetworkRuntime

constructor(context: CoroutineContext)

Properties

proxy

var proxy: ProxyConfig?

When set, all outbound TCP connectTcp dials are tunnelled through this proxy (SOCKS5/HTTP).

selector

val selector: SelectorManager

Functions

bindTcp

suspend fun NetworkRuntime.bindTcp(port: Int, host: String = "0.0.0.0"): TcpServer

Bind a listening TCP socket on host:port (port 0 = an ephemeral free port).

bindUdp

suspend fun NetworkRuntime.bindUdp(port: Int = 0, host: String = "0.0.0.0"): UdpSocket

Bind a UDP socket on host:port (port 0 = any free port). host defaults to the IPv4 wildcard 0.0.0.0; pass "::" to bind the IPv6 (dual-stack on most OSes) wildcard, the way libtorrent's udp_socket::bind honours the listen interface's address family.

fun close()

connectTcp

suspend fun NetworkRuntime.connectTcp(host: String, port: Int, connectTimeoutMs: Long = 0, bypassProxy: Boolean = false): TcpConnection

Open a TCP connection to host:port, tunnelling through NetworkRuntime.proxy if set.