Formatting

Author: TheAngryByrd

src/FsToolkit.ErrorHandling.AsyncSeq/Library.fs

@@ -9,6 +9,7 @@ module AsyncSeqCE =
     type private AsyncSeq<'t> = FSharp.Control.AsyncSeq<'t>
 
     type AsyncResultBuilder with
+
         member inline this.While
             (
                 [<InlineIfLambda>] guard: unit -> Async<option<Result<'T, 'TError>>>,

src/FsToolkit.ErrorHandling.IcedTasks/CancellableTaskResultCE.fs

@@ -1,7 +1,6 @@
 namespace FsToolkit.ErrorHandling
 
 
-
 [<AutoOpen>]
 module CancellableTaskResultCE =
 
@@ -53,7 +52,6 @@ module CancellableTaskResultCE =
         ResumableCode<CancellableTaskResultStateMachineData<'TOverall, 'Error>, 'T>
 
 
-
     module CancellableTaskResultBuilderBase =
 
         let rec WhileDynamic
@@ -126,7 +124,6 @@ module CancellableTaskResultCE =
                 true)
 
 
-
         static member inline CombineDynamic
             (
                 sm: byref<CancellableTaskResultStateMachine<_, _>>,
@@ -182,7 +179,6 @@ module CancellableTaskResultCE =
                     CancellableTaskResultBuilderBase.CombineDynamic(&sm, task1, task2))
 
 
-
         /// Builds a step that executes the body while the condition predicate is true.
         member inline _.While
             (
@@ -194,9 +190,7 @@ module CancellableTaskResultCE =
                     //-- RESUMABLE CODE START
                     let mutable __stack_go = true
 
-                    while __stack_go
-                          && not sm.Data.IsResultError
-                          && condition () do
+                    while __stack_go && not sm.Data.IsResultError && condition () do
                         // NOTE: The body of the state machine code for 'while' may contain await points, so resuming
                         // the code will branch directly into the expanded 'body', branching directly into the while loop
                         let __stack_body_fin = body.Invoke(&sm)
@@ -369,8 +363,8 @@ module CancellableTaskResultCE =
                                 assert not (isNull awaiter)
                                 sm.Data.MethodBuilder.AwaitUnsafeOnCompleted(&awaiter, &sm)
 
-                        with
-                        | exn -> savedExn <- exn
+                        with exn ->
+                            savedExn <- exn
                         // Run SetException outside the stack unwind, see https://github.com/dotnet/roslyn/issues/26567
                         match savedExn with
                         | null -> ()
@@ -405,8 +399,8 @@ module CancellableTaskResultCE =
 
                             if __stack_code_fin && not sm.Data.IsTaskCompleted then
                                 sm.Data.MethodBuilder.SetResult(sm.Data.Result)
-                        with
-                        | exn -> __stack_exn <- exn
+                        with exn ->
+                            __stack_exn <- exn
                         // Run SetException outside the stack unwind, see https://github.com/dotnet/roslyn/issues/26567
                         match __stack_exn with
                         | null -> ()
@@ -462,8 +456,7 @@ module CancellableTaskResultCE =
 
                             if __stack_code_fin && not sm.Data.IsTaskCompleted then
                                 sm.Data.MethodBuilder.SetResult(sm.Data.Result)
-                        with
-                        | exn ->
+                        with exn ->
 
                             // printfn "%A" exn
                             sm.Data.MethodBuilder.SetException exn
@@ -524,9 +517,11 @@ module CancellableTaskResultCE =
         type CancellableTaskResultBuilderBase with
 
             [<NoEagerConstraintApplication>]
-            static member inline BindDynamic< ^TaskLike, 'TResult1, 'TResult2, ^Awaiter, 'TOverall, 'Error when ^TaskLike: (member GetAwaiter:
-                unit -> ^Awaiter) and ^Awaiter :> ICriticalNotifyCompletion and ^Awaiter: (member get_IsCompleted:
-                unit -> bool) and ^Awaiter: (member GetResult: unit -> Result<'TResult1, 'Error>)>
+            static member inline BindDynamic< ^TaskLike, 'TResult1, 'TResult2, ^Awaiter, 'TOverall, 'Error
+                when ^TaskLike: (member GetAwaiter: unit -> ^Awaiter)
+                and ^Awaiter :> ICriticalNotifyCompletion
+                and ^Awaiter: (member get_IsCompleted: unit -> bool)
+                and ^Awaiter: (member GetResult: unit -> Result<'TResult1, 'Error>)>
                 (
                     sm: byref<ResumableStateMachine<CancellableTaskResultStateMachineData<'TOverall, 'Error>>>,
                     task: CancellationToken -> ^TaskLike,
@@ -557,9 +552,11 @@ module CancellableTaskResultCE =
                     false
 
             [<NoEagerConstraintApplication>]
-            member inline _.Bind< ^TaskLike, 'TResult1, 'TResult2, ^Awaiter, 'TOverall, 'Error when ^TaskLike: (member GetAwaiter:
-                unit -> ^Awaiter) and ^Awaiter :> ICriticalNotifyCompletion and ^Awaiter: (member get_IsCompleted:
-                unit -> bool) and ^Awaiter: (member GetResult: unit -> Result<'TResult1, 'Error>)>
+            member inline _.Bind< ^TaskLike, 'TResult1, 'TResult2, ^Awaiter, 'TOverall, 'Error
+                when ^TaskLike: (member GetAwaiter: unit -> ^Awaiter)
+                and ^Awaiter :> ICriticalNotifyCompletion
+                and ^Awaiter: (member get_IsCompleted: unit -> bool)
+                and ^Awaiter: (member GetResult: unit -> Result<'TResult1, 'Error>)>
                 (
                     task: CancellationToken -> ^TaskLike,
                     continuation: ('TResult1 -> CancellableTaskResultCode<'TOverall, 'Error, 'TResult2>)
@@ -603,9 +600,11 @@ module CancellableTaskResultCE =
                 )
 
             [<NoEagerConstraintApplication>]
-            static member inline BindDynamic< ^TaskLike, 'TResult1, 'TResult2, ^Awaiter, 'TOverall, 'Error when ^TaskLike: (member GetAwaiter:
-                unit -> ^Awaiter) and ^Awaiter :> ICriticalNotifyCompletion and ^Awaiter: (member get_IsCompleted:
-                unit -> bool) and ^Awaiter: (member GetResult: unit -> 'TResult1)>
+            static member inline BindDynamic< ^TaskLike, 'TResult1, 'TResult2, ^Awaiter, 'TOverall, 'Error
+                when ^TaskLike: (member GetAwaiter: unit -> ^Awaiter)
+                and ^Awaiter :> ICriticalNotifyCompletion
+                and ^Awaiter: (member get_IsCompleted: unit -> bool)
+                and ^Awaiter: (member GetResult: unit -> 'TResult1)>
                 (
                     sm: byref<ResumableStateMachine<CancellableTaskResultStateMachineData<'TOverall, 'Error>>>,
                     task: ^TaskLike,
@@ -630,9 +629,11 @@ module CancellableTaskResultCE =
                     false
 
             [<NoEagerConstraintApplication>]
-            member inline this.Bind< ^TaskLike, 'TResult1, 'TResult2, ^Awaiter, 'TOverall, 'Error when ^TaskLike: (member GetAwaiter:
-                unit -> ^Awaiter) and ^Awaiter :> ICriticalNotifyCompletion and ^Awaiter: (member get_IsCompleted:
-                unit -> bool) and ^Awaiter: (member GetResult: unit -> 'TResult1)>
+            member inline this.Bind< ^TaskLike, 'TResult1, 'TResult2, ^Awaiter, 'TOverall, 'Error
+                when ^TaskLike: (member GetAwaiter: unit -> ^Awaiter)
+                and ^Awaiter :> ICriticalNotifyCompletion
+                and ^Awaiter: (member get_IsCompleted: unit -> bool)
+                and ^Awaiter: (member GetResult: unit -> 'TResult1)>
                 (
                     task: ^TaskLike,
                     continuation: ('TResult1 -> CancellableTaskResultCode<'TOverall, 'Error, 'TResult2>)
@@ -674,9 +675,11 @@ module CancellableTaskResultCE =
                 )
 
             [<NoEagerConstraintApplication>]
-            member inline this.ReturnFrom< ^TaskLike, ^Awaiter, 'T, 'Error when ^TaskLike: (member GetAwaiter:
-                unit -> ^Awaiter) and ^Awaiter :> ICriticalNotifyCompletion and ^Awaiter: (member get_IsCompleted:
-                unit -> bool) and ^Awaiter: (member GetResult: unit -> 'T)>
+            member inline this.ReturnFrom< ^TaskLike, ^Awaiter, 'T, 'Error
+                when ^TaskLike: (member GetAwaiter: unit -> ^Awaiter)
+                and ^Awaiter :> ICriticalNotifyCompletion
+                and ^Awaiter: (member get_IsCompleted: unit -> bool)
+                and ^Awaiter: (member GetResult: unit -> 'T)>
                 (task: ^TaskLike)
                 : CancellableTaskResultCode<'T, 'Error, 'T> =
 
@@ -690,11 +693,10 @@ module CancellableTaskResultCE =
                 ResumableCode.Using(resource, body)
 
 
-
-
     [<AutoOpen>]
     module HighPriority =
         type Microsoft.FSharp.Control.Async with
+
             static member inline AwaitCancellableTaskResult([<InlineIfLambda>] t: CancellableTaskResult<'T, 'Error>) = async {
                 let! ct = Async.CancellationToken
                 return! t ct |> Async.AwaitTask
@@ -704,13 +706,14 @@ module CancellableTaskResultCE =
                 fun ct -> Async.StartAsTask(computation, cancellationToken = ct)
 
 
-
-
         type CancellableTaskResultBuilder with
 
             [<NoEagerConstraintApplication>]
-            member inline this.Source< ^TaskLike, ^Awaiter, 'T when ^TaskLike: (member GetAwaiter: unit -> ^Awaiter) and ^Awaiter :> ICriticalNotifyCompletion and ^Awaiter: (member get_IsCompleted:
-                unit -> bool) and ^Awaiter: (member GetResult: unit -> 'T)>
+            member inline this.Source< ^TaskLike, ^Awaiter, 'T
+                when ^TaskLike: (member GetAwaiter: unit -> ^Awaiter)
+                and ^Awaiter :> ICriticalNotifyCompletion
+                and ^Awaiter: (member get_IsCompleted: unit -> bool)
+                and ^Awaiter: (member GetResult: unit -> 'T)>
                 (t: ^TaskLike)
                 : CancellableTaskResult<_, _> =
                 // : CancellableTaskResultCode<_,_,_> =
@@ -807,7 +810,6 @@ module CancellableTaskResultCE =
                 this.Bind((task), (fun v -> this.Return v))
 
 
-
     [<AutoOpen>]
     module MediumPriority =
         open HighPriority
@@ -853,6 +855,7 @@ module CancellableTaskResultCE =
 
         // Medium priority extensions
         type CancellableTaskResultBuilderBase with
+
             member inline this.Source(t: Async<'T>) : CancellableTaskResult<'T, 'Error> =
                 fun ct ->
                     let t = t |> Async.map Ok
@@ -862,6 +865,7 @@ module CancellableTaskResultCE =
     [<AutoOpen>]
     module AsyncExtenions =
         type Microsoft.FSharp.Control.AsyncBuilder with
+
             member inline this.Bind
                 (
                     [<InlineIfLambda>] t: CancellableTaskResult<'T, 'Error>,
@@ -874,6 +878,7 @@ module CancellableTaskResultCE =
 
 
         type FsToolkit.ErrorHandling.AsyncResultCE.AsyncResultBuilder with
+
             member inline this.Source([<InlineIfLambda>] t: CancellableTaskResult<'T, 'Error>) : Async<_> =
                 Async.AwaitCancellableTaskResult t
 

src/FsToolkit.ErrorHandling.JobResult/JobOptionCE.fs

@@ -107,6 +107,7 @@ module JobOptionCE =
 module JobOptionCEExtensions =
 
     type JobOptionBuilder with
+
         /// <summary>
         /// Needed to allow `for..in` and `for..do` functionality
         /// </summary>

src/FsToolkit.ErrorHandling.JobResult/JobResult.fs

@@ -17,22 +17,13 @@ module JobResult =
         Job.map (Result.fold onSuccess onError) jr
 
     let inline ofAsync aAsync =
-        aAsync
-        |> Job.fromAsync
-        |> Job.catch
-        |> Job.map Result.ofChoice
+        aAsync |> Job.fromAsync |> Job.catch |> Job.map Result.ofChoice
 
     let inline fromTask aTask =
-        aTask
-        |> Job.fromTask
-        |> Job.catch
-        |> Job.map Result.ofChoice
+        aTask |> Job.fromTask |> Job.catch |> Job.map Result.ofChoice
 
     let inline fromUnitTask aTask =
-        aTask
-        |> Job.fromUnitTask
-        |> Job.catch
-        |> Job.map Result.ofChoice
+        aTask |> Job.fromUnitTask |> Job.catch |> Job.map Result.ofChoice
 
     let inline retn x = Ok x |> Job.result
 
@@ -68,8 +59,7 @@ module JobResult =
     /// The result if the result is Ok, else returns <paramref name="ifError"/>.
     /// </returns>
     let inline orElse (ifError: Job<Result<'ok, 'error2>>) (result: Job<Result<'ok, 'error>>) =
-        result
-        |> Job.bind (Result.either ok (fun _ -> ifError))
+        result |> Job.bind (Result.either ok (fun _ -> ifError))
 
     /// <summary>
     /// Returns <paramref name="result"/> if it is <c>Ok</c>, otherwise executes <paramref name="ifErrorFunc"/> and returns the result.
@@ -117,13 +107,11 @@ module JobResult =
 
     /// Returns Ok if the job-wrapped value and the provided value are equal, or the specified error if not.
     let inline requireEqual x1 x2 error =
-        x2
-        |> Job.map (fun x2' -> Result.requireEqual x1 x2' error)
+        x2 |> Job.map (fun x2' -> Result.requireEqual x1 x2' error)
 
     /// Returns Ok if the two values are equal, or the specified error if not.
     let inline requireEqualTo other error this =
-        this
-        |> Job.map (Result.requireEqualTo other error)
+        this |> Job.map (Result.requireEqualTo other error)
 
     /// Returns Ok if the job-wrapped sequence is empty, or the specified error if not.
     let inline requireEmpty error xs =
@@ -161,8 +149,7 @@ module JobResult =
     /// Extracts the contained value of an job-wrapped result if Ok, otherwise
     /// evaluates ifErrorThunk and uses the result.
     let inline defaultWith ifErrorThunk jobResult =
-        jobResult
-        |> Job.map (Result.defaultWith ifErrorThunk)
+        jobResult |> Job.map (Result.defaultWith ifErrorThunk)
 
     /// Same as defaultValue for a result where the Ok value is unit. The name
     /// describes better what is actually happening in this case.
@@ -185,18 +172,15 @@ module JobResult =
     /// If the job-wrapped result is Error and the predicate returns true,
     /// executes the function on the Error value. Passes through the input value.
     let inline teeErrorIf ([<InlineIfLambda>] predicate) ([<InlineIfLambda>] f) jobResult =
-        jobResult
-        |> Job.map (Result.teeErrorIf predicate f)
+        jobResult |> Job.map (Result.teeErrorIf predicate f)
 
     /// Takes two results and returns a tuple of the pair
     let inline zip j1 j2 =
-        Job.zip j1 j2
-        |> Job.map (fun (r1, r2) -> Result.zip r1 r2)
+        Job.zip j1 j2 |> Job.map (fun (r1, r2) -> Result.zip r1 r2)
 
     /// Takes two results and returns a tuple of the error pair
     let inline zipError j1 j2 =
-        Job.zip j1 j2
-        |> Job.map (fun (r1, r2) -> Result.zipError r1 r2)
+        Job.zip j1 j2 |> Job.map (fun (r1, r2) -> Result.zipError r1 r2)
 
     /// Catches exceptions and maps them to the Error case using the provided function.
     let inline catch f x =

src/FsToolkit.ErrorHandling.TaskResult/Task.fs

@@ -49,6 +49,6 @@ module Task =
         try
             let! r = x
             return Choice1Of2 r
-        with
-        | e -> return Choice2Of2 e
+        with e ->
+            return Choice2Of2 e
     }

src/FsToolkit.ErrorHandling.TaskResult/TaskOption.fs

@@ -27,5 +27,4 @@ module TaskOption =
         bind (fun f' -> bind (fun x' -> retn (f' x')) x) f
 
     let inline zip x1 x2 =
-        Task.zip x1 x2
-        |> Task.map (fun (r1, r2) -> Option.zip r1 r2)
+        Task.zip x1 x2 |> Task.map (fun (r1, r2) -> Option.zip r1 r2)