blob: 2c6556d4a4ae5b1e3876b3303dbf2c74864cd42d (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
|
/* __ *\
** ________ ___ / / ___ Scala API **
** / __/ __// _ | / / / _ | (c) 2005-2011, LAMP/EPFL **
** __\ \/ /__/ __ |/ /__/ __ | http://scala-lang.org/ **
** /____/\___/_/ |_/____/_/ | | **
** |/ **
\* */
package scala
/** This object contains utility methods to build responders.
*
* @author Martin Odersky
* @author Burak Emir
* @version 1.0
*
* @see class Responder
* @since 2.1
*/
object Responder {
/** Creates a responder that answer continuations with the constant
* <code>a</code>.
*
* @param x ...
* @return ...
*/
def constant[A](x: A) = new Responder[A] {
def respond(k: A => Unit) = k(x)
}
/** Executes <code>x</code> and returns <code>true</code>, useful
* as syntactic convenience in for comprehensions.
*
* @param x ...
* @return ...
*/
def exec[A](x: => Unit): Boolean = { x; true }
/** runs a responder, returning an optional result
*/
def run[A](r: Responder[A]): Option[A] = {
var result: Option[A] = None
r.foreach(x => result = Some(x))
result
}
def loop[A](r: Responder[Unit]): Responder[Nothing] =
for (_ <- r; val y <- loop(r)) yield y
def loopWhile[A](cond: => Boolean)(r: Responder[Unit]): Responder[Unit] =
if (cond) for (_ <- r; val y <- loopWhile(cond)(r)) yield y
else constant(())
}
/** Instances of responder are the building blocks of small programs
* written in continuation passing style. By using responder classes
* in for comprehensions, one can embed domain-specific languages in
* Scala while giving the impression that programs in these DSLs are
* written in direct style.
*
* @author Martin Odersky
* @author Burak Emir
* @version 1.0
* @since 2.1
*/
abstract class Responder[+A] extends Serializable {
def respond(k: A => Unit): Unit
def foreach(k: A => Unit) { respond(k) }
def map[B](f: A => B) = new Responder[B] {
def respond(k: B => Unit) {
Responder.this.respond(x => k(f(x)))
}
}
def flatMap[B](f: A => Responder[B]) = new Responder[B] {
def respond(k: B => Unit) {
Responder.this.respond(x => f(x).respond(k))
}
}
def filter(p: A => Boolean) = new Responder[A] {
def respond(k: A => Unit) {
Responder.this.respond(x => if (p(x)) k(x) else ())
}
}
override def toString = "Responder"
}
|