simplify ofObservableBuffered and toBlockingSeq

Author: dsyme

RELEASE_NOTES.md

@@ -1,3 +1,15 @@
+### 1.16.0 - 13.05.2015
+* Simplify ofObservableBuffered and toBlockingSeq
+
+### 1.15.0 - 30.03.2015
+* Add AsyncSeq.getIterator (unblocks use of AsyncSeq in FSharpx.Async)
+
+### 1.14 - 30.03.2015
+* Cancellable AsyncSeq.toBlockingSeq
+* Fix AsyncSeq.scanAsync to also return first state
+* Add a signature file
+* AsyncSeq got extracted as separate project and is now a dependency - https://github.com/fsprojects/FSharpx.Async/pull/24 
+
 ### 1.13 - 27.03.2015
 * Renamed to FSharp.Control.AsyncSeq
 * Remove surface area

docs/content/index.md

@@ -7,7 +7,7 @@ FSharp.Control.AsyncSeq is a collection of asynchronous programming utilities fo
   <div class="span1"></div>
   <div class="span6">
     <div class="well well-small" id="nuget">
-      The FSharp.Control.AsyncSeq library can be <a href="https://nuget.org/packages/AsyncSeq">installed from NuGet</a>:
+      The FSharp.Control.AsyncSeq library can be <a href="http://www.nuget.org/packages/FSharp.Control.AsyncSeq">installed from NuGet</a>:
       <pre>PM> Install-Package FSharp.Control.AsyncSeq</pre>
     </div>
   </div>

src/FSharp.Control.AsyncSeq/AssemblyInfo.fs

@@ -4,9 +4,9 @@ open System.Reflection
 [<assembly: AssemblyTitleAttribute("FSharp.Control.AsyncSeq")>]
 [<assembly: AssemblyProductAttribute("FSharp.Control.AsyncSeq")>]
 [<assembly: AssemblyDescriptionAttribute("Asynchronous sequences for F#")>]
-[<assembly: AssemblyVersionAttribute("1.13")>]
-[<assembly: AssemblyFileVersionAttribute("1.13")>]
+[<assembly: AssemblyVersionAttribute("1.15.0")>]
+[<assembly: AssemblyFileVersionAttribute("1.15.0")>]
 do ()
 
 module internal AssemblyVersionInformation =
-    let [<Literal>] Version = "1.13"
+    let [<Literal>] Version = "1.15.0"

src/FSharp.Control.AsyncSeq/AsyncSeq.fs

@@ -286,7 +286,7 @@ module AsyncSeq =
   let fold f (state:'State) (input : AsyncSeq<'T>) = 
     foldAsync (fun st v -> f st v |> async.Return) state input 
 
-  let rec scan f (state:'State) (input : AsyncSeq<'T>) = 
+  let scan f (state:'State) (input : AsyncSeq<'T>) = 
     scanAsync (fun st v -> f st v |> async.Return) state input 
 
   let map f (input : AsyncSeq<'T>) = 
@@ -608,7 +608,14 @@ module AsyncSeq =
 
   let distinctUntilChanged (s:AsyncSeq<'T>) : AsyncSeq<'T> =
     distinctUntilChangedWith ((=)) s
-        
+
+  let getIterator (s:AsyncSeq<'T>) = 
+      let curr = ref s
+      fun () -> 
+          async { let! v = curr.Value 
+                  match v with 
+                  | Nil -> return None
+                  | Cons (v,t) -> curr := t; return Some v } 
 
 
 

src/FSharp.Control.AsyncSeq/AsyncSeq.fsi

@@ -300,7 +300,8 @@ module AsyncSeq =
     /// Returns an async sequence which contains no contiguous duplicate elements.
     val distinctUntilChanged : s:AsyncSeq<'T> -> AsyncSeq<'T> when 'T : equality
 
-
+    /// Get a function that may be usesd as an async iterator for the sequence. This functionality may be replaced in later versions of this library.
+    val getIterator : s:AsyncSeq<'T> -> (unit -> Async<'T option>)
 
 /// An automatically-opened module tht contains the `asyncSeq` builder and an extension method 
 [<AutoOpen>]

tests/FSharp.Control.AsyncSeq.Tests/AsyncSeqTests.fs

@@ -414,3 +414,21 @@ let ``AsyncSeq.ofObservableBuffered should work (one, take)``() =
   Assert.True(src |> AsyncSeq.ofObservableBuffered |> AsyncSeq.take 1 |> AsyncSeq.toList |> Async.RunSynchronously = [1])
   // Take doesn't correctly run finally clauses, see https://github.com/fsprojects/FSharp.Control.AsyncSeq/issues/15
   //Assert.True(discarded())
+
+[<Test>]
+let ``AsyncSeq.getIterator should work``() =  
+  let s1 = [1..2] |> AsyncSeq.ofSeq
+  let i = AsyncSeq.getIterator s1
+  match i() |> Async.RunSynchronously with 
+  | None -> Assert.Fail("expected Some")
+  | Some v -> 
+    Assert.AreEqual(v,1)
+    match i() |> Async.RunSynchronously with 
+    | None -> Assert.Fail("expected Some")
+    | Some v -> 
+        Assert.AreEqual(v,2)
+        match i() |> Async.RunSynchronously with 
+        | None -> ()
+        | Some _ -> Assert.Fail("expected None")
+
+