Skip to content

Commit a003993

Browse files
committed
Replace use of Async.AwaitTask
1 parent 92b8ca1 commit a003993

File tree

2 files changed

+11
-10
lines changed

2 files changed

+11
-10
lines changed

src/FSharpPlus/Extensions/Async.fs

+8-8
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ namespace FSharpPlus
44
[<RequireQualifiedAccess>]
55
module Async =
66

7-
open System
7+
open FSharpPlus.Extensions
88

99
/// <summary>Creates an async workflow from another workflow 'x', mapping its result with 'f'.</summary>
1010
let map f x = async.Bind (x, async.Return << f)
@@ -43,8 +43,8 @@ module Async =
4343
let! ct = Async.CancellationToken
4444
let x = Async.StartImmediateAsTask (x, ct)
4545
let y = Async.StartImmediateAsTask (y, ct)
46-
let! x' = Async.AwaitTask x
47-
let! y' = Async.AwaitTask y
46+
let! x' = Async.Await x
47+
let! y' = Async.Await y
4848
return f x' y' }
4949
#endif
5050

@@ -62,9 +62,9 @@ module Async =
6262
let x = Async.StartImmediateAsTask (x, ct)
6363
let y = Async.StartImmediateAsTask (y, ct)
6464
let z = Async.StartImmediateAsTask (z, ct)
65-
let! x' = Async.AwaitTask x
66-
let! y' = Async.AwaitTask y
67-
let! z' = Async.AwaitTask z
65+
let! x' = Async.Await x
66+
let! y' = Async.Await y
67+
let! z' = Async.Await z
6868
return f x' y' z' }
6969
#endif
7070

@@ -83,8 +83,8 @@ module Async =
8383
let! ct = Async.CancellationToken
8484
let x = Async.StartImmediateAsTask (x, ct)
8585
let y = Async.StartImmediateAsTask (y, ct)
86-
let! x' = Async.AwaitTask x
87-
let! y' = Async.AwaitTask y
86+
let! x' = Async.Await x
87+
let! y' = Async.Await y
8888
return x', y' }
8989
#endif
9090

src/FSharpPlus/Extensions/AsyncEnumerable.fs

+3-2
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@ open System
66
open System.Threading
77
open System.Threading.Tasks
88
open FSharpPlus.Data
9+
open FSharpPlus.Extensions
910

1011
/// Additional operations on Observable<'T>
1112
[<RequireQualifiedAccess>]
@@ -17,11 +18,11 @@ module AsyncEnumerable =
1718
use _ =
1819
{ new IDisposable with
1920
member _.Dispose () =
20-
e.DisposeAsync().AsTask () |> Async.AwaitTask |> Async.RunSynchronously }
21+
e.DisposeAsync().AsTask () |> Async.Await |> Async.RunSynchronously }
2122

2223
let mutable currentResult = true
2324
while currentResult do
24-
let! r = e.MoveNextAsync().AsTask () |> Async.AwaitTask |> SeqT.lift
25+
let! r = e.MoveNextAsync().AsTask () |> Async.Await |> SeqT.lift
2526
currentResult <- r
2627
if r then yield e.Current
2728
}

0 commit comments

Comments
 (0)