summary refs log tree commit diff stats
path: root/lib/pure/actors.nim
diff options
context:
space:
mode:
authorAdam Strzelecki <ono@java.pl>2015-09-04 23:03:56 +0200
committerAdam Strzelecki <ono@java.pl>2015-09-04 23:03:56 +0200
commit43bddf62dd982e64cd7350eabbbc5d04c5adab21 (patch)
tree30d912ddcdf47201ea5b650d8a0064949fc0472e /lib/pure/actors.nim
parentd68181246571de5799059cf6402f1c578cd9421c (diff)
downloadNim-43bddf62dd982e64cd7350eabbbc5d04c5adab21.tar.gz
lib: Trim .nim files trailing whitespace
via OSX: find . -name '*.nim' -exec sed -i '' -E 's/[[:space:]]+$//' {} +
Diffstat (limited to 'lib/pure/actors.nim')
-rw-r--r--lib/pure/actors.nim10
1 files changed, 5 insertions, 5 deletions
diff --git a/lib/pure/actors.nim b/lib/pure/actors.nim
index da9037285..f0791f954 100644
--- a/lib/pure/actors.nim
+++ b/lib/pure/actors.nim
@@ -41,7 +41,7 @@ type
   Actor[In, Out] = object{.pure, final.}
     i: Channel[Task[In, Out]]
     t: TThread[ptr Actor[In, Out]]
-    
+
   PActor*[In, Out] = ptr Actor[In, Out] ## an actor
 {.deprecated: [TTask: Task, TActor: Actor].}
 
@@ -83,7 +83,7 @@ proc send*[In, Out, X, Y](receiver: PActor[In, Out], msg: In,
   shallowCopy(t.data, msg)
   send(receiver.i, t)
 
-proc send*[In, Out](receiver: PActor[In, Out], msg: In, 
+proc send*[In, Out](receiver: PActor[In, Out], msg: In,
                       sender: ptr Channel[Out] = nil) =
   ## sends a message to `receiver`'s inbox.
   var t: Task[In, Out]
@@ -138,7 +138,7 @@ proc createActorPool*[In, Out](a: var ActorPool[In, Out], poolSize = 4) =
 
 proc sync*[In, Out](a: var ActorPool[In, Out], polling=50) =
   ## waits for every actor of `a` to finish with its work. Currently this is
-  ## implemented as polling every `polling` ms and has a slight chance 
+  ## implemented as polling every `polling` ms and has a slight chance
   ## of failing since we check for every actor to be in `ready` state and not
   ## for messages still in ether. This will change in a later
   ## version, however.
@@ -146,7 +146,7 @@ proc sync*[In, Out](a: var ActorPool[In, Out], polling=50) =
   while true:
     var wait = false
     for i in 0..high(a.actors):
-      if not a.actors[i].i.ready: 
+      if not a.actors[i].i.ready:
         wait = true
         allReadyCount = 0
         break
@@ -222,7 +222,7 @@ proc spawn*[In](p: var ActorPool[In, void], input: In,
   var t: Task[In, void]
   setupTask()
   schedule()
-  
+
 when not defined(testing) and isMainModule:
   var
     a: ActorPool[int, void]