Allowp passing of cancellationToken to Observable.taskUnfold

Jimmy Byrd · Jimmy Byrd · commit 8e125cad7f04 · 2019-07-12T23:41:23.000-04:00
diff --git a/src/FSharp.Control.Redis.Streams.Reactive/FSharp.Control.Redis.Streams.Reactive.fs b/src/FSharp.Control.Redis.Streams.Reactive/FSharp.Control.Redis.Streams.Reactive.fs
@@ -99,7 +99,7 @@ module Reactive =
             | Order.Descending -> EntryId.CalculateNextPositionDesc
             | _ -> failureForMessageOrderCheck ()
 
-        Observable.taskUnfold(fun nextPosition -> task {
+        Observable.taskUnfold(fun nextPosition ct -> task {
             let! (response : StreamEntry []) = readStream nextPosition
             match response with
             | EmptyArray ->
