diff options
author | Li Haoyi <haoyi.sg@gmail.com> | 2019-11-03 19:07:33 +0800 |
---|---|---|
committer | Li Haoyi <haoyi.sg@gmail.com> | 2019-11-03 19:07:33 +0800 |
commit | 57c550990c66845307f77c9cdb44c13d06a7a5c1 (patch) | |
tree | e8934d2c53e6ee2f7f8f1549f5c8841ec2dd66ec /cask | |
parent | c95bf293dbe23fa6c5fd9e23b35a4e4ce34da415 (diff) | |
download | cask-57c550990c66845307f77c9cdb44c13d06a7a5c1.tar.gz cask-57c550990c66845307f77c9cdb44c13d06a7a5c1.tar.bz2 cask-57c550990c66845307f77c9cdb44c13d06a7a5c1.zip |
Basic readme for Cask actors
Diffstat (limited to 'cask')
-rw-r--r-- | cask/actor/test/src-jvm/JvmActorsTest.scala | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/cask/actor/test/src-jvm/JvmActorsTest.scala b/cask/actor/test/src-jvm/JvmActorsTest.scala index 9cfb0d5..61c8e74 100644 --- a/cask/actor/test/src-jvm/JvmActorsTest.scala +++ b/cask/actor/test/src-jvm/JvmActorsTest.scala @@ -11,7 +11,7 @@ object JvmActorsTest extends TestSuite{ var logSize = 0 - def logLine(s: String): Unit = { + def logLine(s: String): Unit = synchronized{ val newLogSize = logSize + s.length + 1 if (newLogSize <= rotateSize) logSize = newLogSize else { @@ -66,7 +66,9 @@ object JvmActorsTest extends TestSuite{ logger.send("I am cow, I am cow") logger.send("Hear me moo, moooo") + // Logger hasn't finished yet, running in the background ac.waitForInactivity() + // Now logger has finished os.read.lines(oldPath) ==> Seq("Comes from liquids from my udder") os.read.lines(logPath) ==> Seq("I am cow, I am cow", "Hear me moo, moooo") |