Tidy

jet · Jun 5, 2023 · be75574 · be75574
1 parent 812b1e7
commit be75574
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/Equinox.Core/AsyncBatchingGate.fs b/src/Equinox.Core/AsyncBatchingGate.fs
@@ -41,7 +41,8 @@ type internal AsyncBatch<'Req, 'Res>() =
 type AsyncBatchingGate<'Req, 'Res>(dispatch: Func<'Req[], CancellationToken, Task<'Res[]>>, [<O; D null>]?linger: TimeSpan) =
     let lingerMs = match linger with None -> 1 | Some x -> int x.TotalMilliseconds
     let mutable cell = AsyncBatch<'Req, 'Res>()
-    new (dispatch: 'Req[] -> Async<'Res[]>, ?linger) = AsyncBatchingGate((fun reqs ct -> Async.startImmediateAsTask ct (dispatch reqs)), ?linger = linger)
+
+    new (dispatch: 'Req[] -> Async<'Res[]>, ?linger) = AsyncBatchingGate((fun reqs ct -> dispatch reqs |> Async.startImmediateAsTask ct), ?linger = linger)
 
     /// Include an item in the batch; await the collective dispatch (subject to the configured linger time)
     member x.ExecuteAsync(req, ct) = task {