AsyncSeq.replicate

Author: eulerfx

src/FSharpx.Async/AsyncSeq.fs

@@ -35,6 +35,10 @@ module AsyncSeq =
   let singleton (v:'T) : AsyncSeq<'T> = 
     async { return Cons(v, empty) }
 
+  /// Creates an async sequence which repeats the specified value indefinitely.
+  let rec replicate (v:'T) : AsyncSeq<'T> =
+    Cons(v, async.Delay <| fun() -> replicate v) |> async.Return    
+
   /// Yields all elements of the first asynchronous sequence and then 
   /// all elements of the second asynchronous sequence.
   let rec append (seq1: AsyncSeq<'T>) (seq2: AsyncSeq<'T>) : AsyncSeq<'T> = 

tests/FSharpx.Async.Tests/AsyncSeqTests.fs

@@ -201,6 +201,11 @@ let ``AsyncSeq.merge should be fair``() =
   let expected = [2;1] |> AsyncSeq.ofSeq
   Assert.True(EQ expected actual)
 
-
-
+[<Test>]
+let ``AsyncSeq.replicate``() =
+  let c = 10
+  let x = "hello"
+  let actual = AsyncSeq.replicate x |> AsyncSeq.take c
+  let expected = List.replicate c x |> AsyncSeq.ofSeq
+  Assert.True(EQ expected actual)