blob: 53bfd737cd973932ae30d77e87f0e730716b1956 (
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
|
@deprecated("Suppress warnings", since="2.11")
object Test {
import scala.actors.{Actor, Exit, !, UncaughtException}
import Actor._
case class ImageInfo(text: String) {
def downloadImage(): ImageData = {
ImageData(text)
}
}
case class ImageData(text: String)
case class Download(info: ImageInfo)
def scanForImageInfo(url: String): List[ImageInfo] =
List(ImageInfo("A"), ImageInfo("B"))
def renderImage(data: ImageData) {
println("rendering image "+data.text)
}
def renderImages(url: String) {
val imageInfos = scanForImageInfo(url)
println("sending download requests")
val dataFutures = for (info <- imageInfos) yield {
val loader = link {
react { case Download(info) =>
throw new Exception("no connection")
reply(info.downloadImage())
}; {}
}
loader !! Download(info)
}
var i = 0
loopWhile (i < imageInfos.size) {
i += 1
val FutureInput = dataFutures(i-1).inputChannel
react {
case FutureInput ! (data @ ImageData(_)) =>
renderImage(data)
case Exit(from, UncaughtException(_, Some(Download(info)), _, _, cause)) =>
println("Couldn't download image because of "+cause)
}
}
println("OK, all images rendered.")
}
def main(args: Array[String]) {
actor {
self.trapExit = true
renderImages("panorama.epfl.ch")
}
}
}
|
