Anonymous user
Echo server: Difference between revisions
→{{header|Scala}}
Line 1,942:
class ClientHandler(clientSocket: Socket) extends Runnable {
private val (connectionId
override def run(): Unit =
new PrintWriter(clientSocket.getOutputStream, true) {
println(s"Connection opened, close with entering '$closeCmd'.")
Source.fromInputStream(clientSocket.getInputStream).getLines
.takeWhile(!_.toLowerCase.startsWith(
.foreach { line =>
Console.println(s"Received on #$connectionId: $line")
| |||