fixed race condition in FoldSelect

Author: rssh

build.sbt

@@ -3,8 +3,8 @@ name:="scala-gopher"
 
 organization:="com.github.rssh"
 
-scalaVersion := "2.12.0"
-crossScalaVersions := Seq("2.11.8", "2.12.0")
+scalaVersion := "2.12.1"
+crossScalaVersions := Seq("2.11.8", "2.12.1")
 
 resolvers += Resolver.sonatypeRepo("snapshots")
 
@@ -22,7 +22,7 @@ libraryDependencies += "org.scala-lang.modules" %% "scala-async" % "0.9.6"
 
 libraryDependencies += "org.scalatest" %% "scalatest" % "3.0.0" % "test"
 
-libraryDependencies += "com.typesafe.akka" %% "akka-actor" % "2.4.12"
+libraryDependencies += "com.typesafe.akka" %% "akka-actor" % "2.4.14"
 
 //TODO: enable after 1.0
 //libraryDependencies += "com.typesafe.akka" %% "akka-stream-experimental" % "0.9"

notes/0.99.8.markdown

@@ -8,5 +8,6 @@ ie in simplicified explanation:
 ```
  1.to(n).foreachAsync { async(s += await(aread(x))) }  
 ```
+details can be found in techreport: https://arxiv.org/abs/1611.00602
 - added support for select.fold construct
 - scala 2.12

src/main/scala/gopher/channels/ChannelProcessor.scala

@@ -26,7 +26,7 @@ class ChannelProcessor(api: GopherAPI) extends Actor
                               }
                              }
       case cr@ContRead(f,ch, ft) =>  
-                                     if (!ft.isCompleted) {
+                                    if (!ft.isCompleted) {
                                        ch.cbread[cr.R](f,ft)
                                     }
       case cw@ContWrite(f,ch, ft) =>  

src/main/scala/gopher/channels/Continuated.scala

@@ -126,6 +126,11 @@ object ContWrite
  */
 case class Skip[A](function: Skip[A] => Option[Future[Continuated[A]]], override val flowTermination: FlowTermination[A]) extends FlowContinuated[A]
 
+object Skip
+{
+  type AuxF[A] = Skip[A]=>Option[Future[Continuated[A]]]
+}
+
 /**
  * never means the end of conversation
  */

src/main/scala/gopher/channels/DuppedInput.scala

@@ -37,7 +37,6 @@ class DuppedInput[A](origin:Input[A])
   def api = origin.api
   private implicit def ec:ExecutionContext = api.executionContext
 
-  private var closed = false
 
 
 }