Experiments with concurrency.

Result values, both anonymous and named, are updated when complete. Even works with flatMap. Amazing!

import scala.concurrent._

import scala.concurrent._

implicit val ec = ExecutionContext.global

ec: ExecutionContextExecutor = scala.concurrent.impl.ExecutionContextImpl@400242ba

Future(println("Hello"))
Future(3)

Hello

res2_0: Future[Unit] = [running]
res2_1: Future[Int] = Success(3)

Thread.sleep(1000)

Future{Thread.sleep(3000); 3}

res4: Future[Int] = Success(3)

Future{Thread.sleep(10000); 30}

res5: Future[Int] = Success(30)

Future{Thread.sleep(3000); 3 ; println("completed")}

res6: Future[Unit] = Success(())

val n = 3
val fut = Future{Thread.sleep(3000); n}

n: Int = 3
fut: Future[Int] = Success(3)

val fut = Future{Thread.sleep(3000); 3}
val fut1 = fut.flatMap{k => Future{Thread.sleep(5000); k * k}}

fut: Future[Int] = Success(3)
fut1: Future[Int] = Success(9)

val futVec = (1 to 10).toVector.map(n => Future{Thread.sleep(1000 * n); n})
val allDone = Future.sequence(futVec)

futVec: Vector[Future[Int]] = Vector(
  Success(1),
  Success(2),
  Success(3),
  Success(4),
  Success(5),
  Success(6),
  Success(7),
  Success(8),
  Success(9),
  Success(10)
)
allDone: Future[Vector[Int]] = Success(Vector(1, 2, 3, 4, 5, 6, 7, 8, 9, 10))

import sys.process._
println("git log -1".!!)

commit 67cebb5501c7d1643042c9f3b27fd7a31d5b1b70
Author: Siddhartha Gadgil <siddhartha.gadgil@gmail.com>
Date:   Sat Sep 14 20:51:58 2019 +0530

    handles in almond

import sys.process._

import $ivy.`io.monix::monix:3.0.0`

import $ivy.$                      

import monix.eval._

import monix.eval._

Task(3)

res13: Task[Int] = Eval(
  ammonite.$sess.cmd13$Helper$$Lambda$3060/1851591291@681c652f
)

val task3 = Task.deferFuture(Future{Thread.sleep(6000); 3}(ec)).memoize

task3: Task[Int] = Async(<function2>, false, true, true)

import monix.execution.Scheduler.Implicits.global
val fut3 = task3.runToFuture

import monix.execution.Scheduler.Implicits.global

fut3: monix.execution.CancelableFuture[Int] = Success(3)

task3

res16: Task[Int] = Async(<function2>, false, true, true)

task3.runToFuture

res17: monix.execution.CancelableFuture[Int] = Success(3)

val id = java.util.UUID.randomUUID().toString
kernel.publish.html("Starting", id)

for (i <- 1 to 10) {
  Thread.sleep((200.0 + 200.0 * scala.util.Random.nextGaussian).toLong max 0L)
  kernel.publish.updateHtml(s"Got item <b>#$i</b>", id)
}

kernel.publish.updateHtml("Got all items", id)

Got all items

id: String = "1d50ca78-679b-4e7d-b690-e9ff66705b38"

for (i <- 1 to 10) {
  kernel.publish.html(s"Got item <b>#$i</b>")
  Thread.sleep((200.0 + 200.0 * scala.util.Random.nextGaussian).toLong max 0L)
}

Got item #1

Got item #2

Got item #3

Got item #4

Got item #5

Got item #6

Got item #7

Got item #8

Got item #9

Got item #10

import almond.display._
Html("<b>Bold stuff</b>")

Bold stuff

import almond.display._

val handle = Html("<p> stuff comes here </p>")

handle.withContent("<b>Stuff becomes bold</b>").update()

val svgText = """<svg version="1.1"
     baseProfile="full"
     width="300" height="200"
     xmlns="http://www.w3.org/2000/svg">

  <rect width="100%" height="100%" fill="red" />

  <circle cx="150" cy="100" r="80" fill="green" />

  <text x="150" y="125" font-size="60" text-anchor="middle" fill="white">SVG</text>

</svg>"""

svgText: String = """<svg version="1.1"
     baseProfile="full"
     width="300" height="200"
     xmlns="http://www.w3.org/2000/svg">

  <rect width="100%" height="100%" fill="red" />

  <circle cx="150" cy="100" r="80" fill="green" />

  <text x="150" y="125" font-size="60" text-anchor="middle" fill="white">SVG</text>

</svg>"""

Html(svgText)

Future{Thread.sleep(5000); handle.withContent(svgText).update() }(ec)

res25: Future[Unit] = Success(())

handle.data

res31: Map[String, String] = Map("text/html" -> "<p> stuff comes here </p>")

handle.displayId

res32: String = "4b61dd5f-e0eb-47fd-8bac-0d6395d88d32"

handle.url

res34: Option[java.net.URL] = None

handle.contentOrUrl

res35: Either[java.net.URL, String] = Right("<p> stuff comes here </p>")

handle.metadata

res36: Map[String, String] = Map()

interp

res26: ammonite.interp.api.InterpAPI = ammonite.interp.Interpreter$$anon$1@3af381b7

interp.repositories

res27: util.Ref[List[coursierapi.Repository]] = Ref(ammonite.util.Ref$$anon$1$$Lambda$173/760846326@28ab3ce7)

Image

res28: Image.type = almond.display.Image$@79edf603

Image.JPG

res29: Image.JPG.type = JPG