Skip to content

Commit 9d6c6f3

Browse files
committed
more sync over async
1 parent a35f98b commit 9d6c6f3

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

src/Compiler/Utilities/Async2.fs

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -498,16 +498,16 @@ module Async2 =
498498

499499
let runWithoutCancellation code = run CancellationToken.None code
500500

501-
let startAsTaskWithoutCancellation code =
502-
start CancellationToken.None code |> _.Task
503-
504501
let queueTask ct code =
505502
Task.Run<'t>(fun () -> start ct code |> _.Task)
506503

504+
let startAsTaskWithoutCancellation code =
505+
queueTask CancellationToken.None code
506+
507507
let toAsync (code: Async2<'t>) =
508508
async {
509509
let! ct = Async.CancellationToken
510-
let task = start ct code |> _.Task
510+
let task = queueTask ct code
511511
return! Async.AwaitTask task
512512
}
513513

@@ -533,7 +533,7 @@ type Async2 =
533533

534534
static member StartAsTask(computation: Async2<_>, ?cancellationToken: CancellationToken) : Task<_> =
535535
let ct = defaultArg cancellationToken CancellationToken.None
536-
Async2.start ct computation |> _.Task
536+
Async2.queueTask ct computation
537537

538538
static member RunImmediate(computation: Async2<'T>, ?cancellationToken: CancellationToken) : 'T =
539539
let ct = defaultArg cancellationToken CancellationToken.None
@@ -583,12 +583,12 @@ type Async2 =
583583
static member TryCancelled(computation: Async2<'T>, compensation) =
584584
async2 {
585585
let! ct = Async2.CancellationToken
586-
let task = computation |> Async2.start ct |> _.Task
586+
let invocation = Async2.start ct computation
587587

588588
try
589-
return! task
589+
return! invocation
590590
finally
591-
if task.IsCanceled then
591+
if invocation.Task.IsCanceled then
592592
compensation ()
593593
}
594594

0 commit comments

Comments
 (0)