|
import "net" for Server
|
|
import "scheduler" for Scheduler
|
|
|
|
var port = 9090
|
|
var server = Server.bind("0.0.0.0", port)
|
|
System.print("Echo Server running on port %(port)")
|
|
|
|
while (true) {
|
|
var socket = server.accept()
|
|
System.print("New connection accepted")
|
|
|
|
Fiber.new {
|
|
var socket_ = socket // Capture variable
|
|
while (true) {
|
|
var data = socket_.read()
|
|
if (data == null) {
|
|
break
|
|
}
|
|
System.print("Received: %(data.count) bytes")
|
|
socket_.write(data)
|
|
}
|
|
System.print("Connection closed")
|
|
socket_.close()
|
|
}.call()
|
|
}
|