raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

formatting fixes

Browse source
This commit is contained in:
Derek Williams 2011-07-26 17:58:37 -06:00
parent ebc50b5acd
commit 749b63e732
4 changed files with 6 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-actor-tests/src/test/scala/akka/dispatch/FutureSpec.scala
View file

@ -309,7 +309,7 @@ class FutureSpec extends WordSpec with MustMatchers with Checkers with BeforeAnd
Futures.fold(0, timeout)(futures)(_ + _).await.exception.get.getMessage must be("shouldFoldResultsWithException: expected")
}
/* @Test
/* @Test
def shouldFoldMutableZeroes {
import scala.collection.mutable.ArrayBuffer
def test(testNumber: Int) {

2
akka-actor-tests/src/test/scala/akka/misc/SchedulerSpec.scala
View file

@ -27,7 +27,7 @@ class SchedulerSpec extends JUnitSuite {
@After
def afterEach {
while(futures.peek() ne null) { Option(futures.poll()).foreach(_.cancel(true)) }
while (futures.peek() ne null) { Option(futures.poll()).foreach(_.cancel(true)) }
Actor.registry.local.shutdownAll
EventHandler.start()
}

2
akka-actor/src/main/scala/akka/actor/IO.scala
View file

@ -206,7 +206,7 @@ trait IO {
_next = continuation(bytes)
run()
}
case bsd@ByteStringDelimited(continuation, handle, message, delimiter, inclusive, scanned) ⇒
case bsd @ ByteStringDelimited(continuation, handle, message, delimiter, inclusive, scanned) ⇒
self.currentMessage = message
val st = state(handle)
val idx = st.readBytes.indexOfSlice(delimiter, scanned)

6
akka-tutorials/akka-tutorial-second/src/main/scala/Pi.scala
View file

@ -8,7 +8,7 @@ import akka.actor.Actor._
import akka.routing.{ Routing, CyclicIterator }
import Routing._
import akka.event.EventHandler
import akka.actor.{Channel, Actor, PoisonPill, Timeout}
import akka.actor.{ Channel, Actor, PoisonPill, Timeout }
import akka.dispatch.Future
import System.{ currentTimeMillis ⇒ now }
@ -105,8 +105,8 @@ object Pi extends App {
//send calculate message
master.?(Calculate, Timeout(60000)).
await.resultOrException match {//wait for the result, with a 60 seconds timeout
case Some(pi) =>
await.resultOrException match { //wait for the result, with a 60 seconds timeout
case Some(pi) ⇒
EventHandler.info(this, "\n\tPi estimate: \t\t%s\n\tCalculation time: \t%s millis".format(pi, (now - start)))
case None ⇒
EventHandler.error(this, "Pi calculation did not complete within the timeout.")