Merge pull request #2 from danielrbradley/fix-async-seq-skip-bug

Fix bug where AsyncSeq.skipWhile skips an extra item

Author: forki

src/FSharpx.Async/AsyncSeq.fs

@@ -439,10 +439,10 @@ module AsyncSeq =
   let rec skipWhileAsync p (input : AsyncSeq<'T>) : AsyncSeq<_> = async {
     let! v = input
     match v with
-    | Cons(h, t) -> 
+    | Cons(h, t) ->
         let! res = p h
         if res then return! skipWhileAsync p t
-        else return! t
+        else return v
     | Nil -> return Nil }
 
   /// Returns elements from an asynchronous sequence while the specified 

tests/FSharpx.Async.Tests/AsyncSeqTests.fs

@@ -0,0 +1,15 @@
+module AsyncSeqTests
+
+open NUnit.Framework
+open FSharpx.Control
+
+[<Test>]
+let ``skipping should return all elements after the first non-match``() =
+    let expected = [ 3; 4 ]
+    let result = 
+        [ 1; 2; 3; 4 ] 
+        |> AsyncSeq.ofSeq 
+        |> AsyncSeq.skipWhile (fun i -> i <= 2) 
+        |> AsyncSeq.toBlockingSeq 
+        |> Seq.toList
+    Assert.AreEqual(expected, result)

tests/FSharpx.Async.Tests/FSharpx.Async.Tests.fsproj

@@ -58,6 +58,7 @@
   <Import Project="$(SolutionDir)\.nuget\NuGet.targets" Condition="Exists('$(SolutionDir)\.nuget\NuGet.targets')" />
   <ItemGroup>
     <Compile Include="AsyncTest.fs" />
+    <Compile Include="AsyncSeqTests.fs" />
     <None Include="paket.references" />
   </ItemGroup>
   <ItemGroup>