unbuffered channels now by default (as in go)

Author: rssh

src/main/scala/gopher/GopherAPI.scala

@@ -41,7 +41,7 @@ class GopherAPI(as: ActorSystem, es: ExecutionContext)
    *  channel.awrite(1 to 100)
    *}}}
    */
-  def makeChannel[A](capacity: Int = 1) =
+  def makeChannel[A](capacity: Int = 0) =
     {
      require(capacity >= 0)
      val nextId = newChannelId

src/main/scala/gopher/channels/Channel.scala

@@ -14,6 +14,7 @@ import scala.reflect.api._
 abstract class Channel[A](override val api: GopherAPI) extends InputOutput[A]
 {
 
+
    def close(): Unit
 
 }

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

@@ -15,8 +15,8 @@ class DuppedInput[A](origin:Input[A])
 
   def pair = (sink1, sink2)
 
-  val sink1 = api.makeChannel[A]()
-  val sink2 = api.makeChannel[A]()
+  val sink1 = api.makeChannel[A](1)
+  val sink2 = api.makeChannel[A](1)
 
   // can't use macroses, so unroll by hands.
   private val selector = api.select.forever;

src/test/scala/gopher/channels/DuppedChannelsSuite.scala

@@ -49,7 +49,7 @@ class DuppedChannelsSuite extends FunSuite with AsyncAssertions {
   }
 
   test("on closing of main stream dupped outputs also closed.") {
-      val ch = gopherApi.makeChannel[Int]()
+      val ch = gopherApi.makeChannel[Int](1)
       val (in1, in2) = ch.dup
       val f1 = go {
           ch.write(1) 

src/test/scala/gopher/channels/IOTimeoutsSuite.scala

@@ -47,7 +47,7 @@ class IOTimeoutsSuite extends FunSuite with AsyncAssertions {
 
   test("on input close it's timeout channel also must close") {
       val w = new Waiter()
-      val ch = gopherApi.makeChannel[String]()
+      val ch = gopherApi.makeChannel[String](1)
       Await.ready(ch.awrite("qqq"), 1 second)
       val (chReady, chTimeout) = ch.withInputTimeouts(300 milliseconds)
       ch.close()
@@ -73,10 +73,25 @@ class IOTimeoutsSuite extends FunSuite with AsyncAssertions {
   }
 
 
-  test("messsaged from timeouts must be appear during attempt to write to filled channel") {
+  test("messsaged from timeouts must be appear during attempt to write to filled unbuffered channel") {
       val ch = gopherApi.makeChannel[Int]()
       val (chReady, chTimeout) = ch.withOutputTimeouts(150 milliseconds)
       @volatile var count = 1
+      val f = gopherApi.select.forever {
+                case x: chReady.write if (x==count) => 
+                            {};
+                            count += 1  // will newer called, since we have no reader
+                case t: chTimeout.read =>
+                            implicitly[FlowTermination[Unit]].doExit(count)
+              }
+      Await.ready(f, 1 second)
+      assert(count==1)
+  }
+
+  test("messsaged from timeouts must be appear during attempt to write to filled buffered channel") {
+      val ch = gopherApi.makeChannel[Int](1)
+      val (chReady, chTimeout) = ch.withOutputTimeouts(150 milliseconds)
+      @volatile var count = 1
       val f = gopherApi.select.forever {
                 case x: chReady.write if (x==count) => 
                             {};
@@ -89,7 +104,7 @@ class IOTimeoutsSuite extends FunSuite with AsyncAssertions {
   }
 
   test("when we have where to write -- no timeouts") {
-      val ch = gopherApi.makeChannel[Int]()
+      val ch = gopherApi.makeChannel[Int](1)
       val (chReady, chTimeout) = ch.withOutputTimeouts(300 milliseconds)
       val f = gopherApi.select.once {
                  case x: chReady.write if (x==1) => 1
@@ -100,7 +115,7 @@ class IOTimeoutsSuite extends FunSuite with AsyncAssertions {
   }
 
   test("on output close it's timeout channel also must close") {
-      val ch = gopherApi.makeChannel[Int]()
+      val ch = gopherApi.makeChannel[Int](1)
       val (chReady, chTimeout) = ch.withOutputTimeouts(300 milliseconds)
       val w = new Waiter()
       val f1 = chReady.awrite(1)