added Output.unfold

rssh · rssh · commit cc767222f702 · 2016-10-21T08:09:05.000+03:00
diff --git a/src/main/scala/gopher/channels/Output.scala b/src/main/scala/gopher/channels/Output.scala
@@ -82,6 +82,13 @@ trait Output[A] extends GopherAPIProvider
 
   def writeAll[C <: Iterable[A]](it:C):Unit = macro Output.writeAllImpl[A,C]
 
+  def unfold[S](s:S)(f:S=>(S,A)):Unit =
+  {
+   var ca=f(s)
+   val fs = api.select.forever
+   fs.writingWithFlowTerminationAsync[A](this,ca._2,(ec,ft,a) => Future successful {ca=f(ca._1)} )
+   fs.go
+  }
   
   /**
    *provide pair from Output and Input `(ready, timeouts)` such that writing to `ready` 
