Scala Samples

javaish.scala

for(i <- 1 to 10) {
	if (isSocketOpen) return
	Thread.sleep(duration/10)
}
sys.error("Timed out")

range.scala

val range: Seq[Int] = 1 to MAX_CONNECTION_ATTEMPTS
range.flatMap(checkSocketOpen).headOption match {
	case None => sys.error("Timed out")
	case _ =>
}

recursive.scala

def checkOpen(currentTry: Int) {
	if (currentTry > MAX_CONNECTION_ATTEMPTS)
		sys.error("Timed out")
	try new Socket(host.name, port.toInt).close()
	catch { case e: IOException => {
		Thread.sleep(duration/MAX_CONNECTION_ATTEMPTS)
		checkOpen(currentTry + 1)
		}
	}
}
checkOpen(0)

spawn_test.scala

spawn {
	val server = new ServerSocket(9998)
	server.accept().close()
	server.close()
}

test_evaluating.scala

evaluating {
	task.execute()
} should produce [RuntimeException]