added test for one-time channel

Author: rssh

build.sbt

@@ -23,10 +23,13 @@ libraryDependencies += "com.typesafe.akka" %% "akka-actor" % "2.4.4"
 //libraryDependencies += "com.typesafe.akka" %% "akka-stream-experimental" % "0.9"
 
 //testOptions in Test += Tests.Argument(TestFrameworks.ScalaTest, "-n", "Now")
+//fork in Test := true
+//javaOptions in Test += s"""-javaagent:${System.getProperty("user.home")}/.ivy2/local/com.github.rssh/trackedfuture_2.11/0.3/jars/trackedfuture_2.11-assembly.jar"""
 
 version:="0.99.7-SNAPSHOT"
 
 
+
 publishMavenStyle := true
 
 publishTo <<= version { (v: String) =>

src/main/scala/gopher/channels/OneTimeChannel.scala

@@ -7,11 +7,16 @@ import java.util.concurrent.atomic._
 /**
  * channel, in which only one message can be written,
  * after which it is automatically closed
+ *
+ * Writer is not waiting for reader to start.   
  */
 class OneTimeChannel[T](override val api:GopherAPI) extends Channel[T]
 {
-  val p = Promise[T]()
-  val readed = new AtomicBoolean(false)
+  private[this] val p = Promise[T]()
+  private[this] val readed = new AtomicBoolean(false)
+
+  def future = p.future
+  def promise = p
 
   def cbread[B](f: ContRead[T,B] => Option[ContRead.In[T] => Future[Continuated[B]]],ft: FlowTermination[B]): Unit = 
   {
@@ -29,11 +34,11 @@ class OneTimeChannel[T](override val api:GopherAPI) extends Channel[T]
   def cbwrite[B](f: ContWrite[T,B] => Option[(T, Future[Continuated[B]])],ft: FlowTermination[B]): Unit = 
   {
     if (p.isCompleted) {
-       throw new ChannelClosedException()
+       ft.doThrow(new ChannelClosedException())
     } else {
        f(ContWrite(f,this,ft)) foreach { case (a, next) =>
            if (!p.trySuccess(a)) {
-             throw new ChannelClosedException()
+             ft.doThrow(throw new ChannelClosedException())
            }
            api.continue(next,ft)
        }
@@ -45,3 +50,11 @@ class OneTimeChannel[T](override val api:GopherAPI) extends Channel[T]
        p failure new ChannelClosedException()
 
 }
+
+object OneTimeChannel
+{
+
+  def apply[A]()(implicit api:GopherAPI): OneTimeChannel[A] =
+    new OneTimeChannel[A](api)
+
+}

src/test/scala/gopher/channels/MacroSelectSuite.scala

@@ -324,6 +324,16 @@ class MacroSelectSuite extends FunSuite
      assert(s1==3 || s1==10)
    }
 
+   test("one-time channel make")  {
+     import gopherApi._
+     val ch = gopherApi.make[OneTimeChannel[Int]]()
+     val f1 = ch.awrite(1)
+     val f2 = ch.awrite(2)
+     val x = Await.result(ch.aread, 10 seconds)
+     val x2 = Await.result(f2.failed, 10 seconds)
+     assert(x==1)
+     assert(x2.isInstanceOf[ChannelClosedException])
+   }
 
    lazy val gopherApi = CommonTestObjects.gopherApi