dagr
0.4.3indexedOffers a UDP client-server API for seamless communication, facilitating integration into projects through specified dependencies.
0
Stars
—
Used by
dependents
—
Health
/ 100
Dagr
TCP Client-Server API
Integration
kotlin {
sourceSets {
commonMain.dependencies {
...
implementation("io.github.remmerw:dagr:0.4.3")
}
...
}
}
API
@Test
fun testDagr(): Unit = runBlocking(Dispatchers.IO) {
val serverData = "Moin".encodeToByteArray()
val server = newDagr(port = 0, timeout = 5, acceptor = object : Acceptor {
override suspend fun request(request: Long): Data {
assertEquals(request, 1)
val buffer = Buffer()
buffer.write(serverData)
return Data(buffer, serverData.size)
}
})
val remoteAddress = InetSocketAddress(
InetAddress.getLoopbackAddress(), server.localPort()
)
val connection = connectDagr(remoteAddress)!!
val buffer = Buffer()
connection.request(1, buffer)
assertContentEquals(buffer.readByteArray(), serverData)
connection.close()
server.shutdown()
}