Upgrade Prelude to v5 and F# to v6

src/SqlStreamStore.FSharp.Postgres/Create.fs

@@ -1,6 +1,6 @@
 namespace SqlStreamStore.FSharp.Postgres
 
-open FSharp.Prelude
+open Prelude.ErrorHandling
 open SqlStreamStore
 
 type PostgresConfig =

src/SqlStreamStore.FSharp.Postgres/SqlStreamStore.FSharp.Postgres.fsproj

@@ -16,6 +16,8 @@
     </ItemGroup>
 
     <ItemGroup>
+        <PackageReference Update="FSharp.Core" Version="6.0.*"/>
+        <PackageReference Include="FSharp.Core" Version="6.0.*"/>
         <PackageReference Include="SqlStreamStore.Postgres" Version="1.2.0-beta.8"/>
     </ItemGroup>
 

src/SqlStreamStore.FSharp/Append.fs

@@ -1,6 +1,6 @@
 namespace SqlStreamStore.FSharp
 
-open FSharp.Prelude
+open Prelude.ErrorHandling
 open System.Threading
 open SqlStreamStore
 

src/SqlStreamStore.FSharp/Extensions.fs

@@ -1,7 +1,7 @@
 namespace SqlStreamStore.FSharp
 
 open System.Threading
-open FSharp.Prelude
+open Prelude.ErrorHandling
 open SqlStreamStore
 open SqlStreamStore.Streams
 open System

src/SqlStreamStore.FSharp/Get.fs

@@ -1,12 +1,12 @@
 namespace SqlStreamStore.FSharp
 
-open FSharp.Prelude
+open Prelude.ErrorHandling
 open SqlStreamStore.Streams
 
 module Get =
 
     // A function to help wit type inference in this module
-    let private curriedMap : (ReadStreamPage -> 'a) -> AsyncResult<ReadStreamPage, exn> -> AsyncResult<'a, exn> =
+    let private curriedMap: (ReadStreamPage -> 'a) -> AsyncResult<ReadStreamPage, exn> -> AsyncResult<'a, exn> =
         AsyncResult.map
 
     let messages =
@@ -44,7 +44,7 @@ module Get =
 module GetAll =
 
     // A function to help wit type inference in this module
-    let private curriedMap : (ReadAllPage -> 'a) -> AsyncResult<ReadAllPage, exn> -> AsyncResult<'a, exn> =
+    let private curriedMap: (ReadAllPage -> 'a) -> AsyncResult<ReadAllPage, exn> -> AsyncResult<'a, exn> =
         AsyncResult.map
 
     let messages =

src/SqlStreamStore.FSharp/Read.fs

@@ -1,6 +1,6 @@
 namespace SqlStreamStore.FSharp
 
-open FSharp.Prelude
+open Prelude.ErrorHandling
 open System.Threading
 open SqlStreamStore
 open SqlStreamStore.Streams
@@ -36,7 +36,7 @@ module Read =
     let partial' (readOptions: ReadPartialOption list) (Stream stream: Stream) : AsyncResult<ReadStreamPage, exn> =
 
         let mutable cancellationToken = Unchecked.defaultof<CancellationToken>
-        let mutable fromVersionInclusive : int option = None
+        let mutable fromVersionInclusive: int option = None
         let mutable messageCount = 1000
         let mutable prefetch = true
         let mutable readDirection = ReadDirection.Forward
@@ -79,12 +79,12 @@ module Read =
             )
         | _ -> failwith "Illegal ReadDirection enum."
 
-    let partial : Stream -> AsyncResult<ReadStreamPage, exn> = partial' []
+    let partial: Stream -> AsyncResult<ReadStreamPage, exn> = partial' []
 
     let entire' (readOptions: ReadEntireOption list) : Stream -> AsyncResult<ReadStreamPage, exn> =
 
         let mutable cancellationToken = Unchecked.defaultof<CancellationToken>
-        let mutable fromVersionInclusive : int option = None
+        let mutable fromVersionInclusive: int option = None
         let mutable prefetch = true
         let mutable readDirection = ReadDirection.Forward
 
@@ -119,12 +119,12 @@ module Read =
 
         partial' (options @ options')
 
-    let entire : Stream -> AsyncResult<ReadStreamPage, exn> = entire' []
+    let entire: Stream -> AsyncResult<ReadStreamPage, exn> = entire' []
 
     let allStream' (readOptions: ReadAllOption list) : IStreamStore -> AsyncResult<ReadAllPage, exn> =
 
         let mutable cancellationToken = Unchecked.defaultof<CancellationToken>
-        let mutable fromPositionInclusive : int64 option = None
+        let mutable fromPositionInclusive: int64 option = None
         let mutable messageCount = 1000
         let mutable prefetch = true
         let mutable readDirection = ReadDirection.Forward
@@ -165,4 +165,4 @@ module Read =
                 )
             | _ -> failwith "Illegal ReadDirection enum."
 
-    let allStream : IStreamStore -> AsyncResult<ReadAllPage, exn> = allStream' []
+    let allStream: IStreamStore -> AsyncResult<ReadAllPage, exn> = allStream' []

src/SqlStreamStore.FSharp/SqlStreamStore.FSharp.fsproj

@@ -13,14 +13,6 @@
         <OtherFlags>$(OtherFlags) --warnon:1182</OtherFlags>
     </PropertyGroup>
 
-    <ItemGroup>
-        <PackageReference Update="FSharp.Core" Version="5.0.0"/>
-        <PackageReference Include="FSharp.Core" Version="5.0.0"/>
-        <PackageReference Include="FSharp.Prelude" Version="4.0.*"/>
-        <PackageReference Include="Npgsql" Version="5.0.*"/>
-        <PackageReference Include="SqlStreamStore" Version="1.2.0-beta.8"/>
-    </ItemGroup>
-
     <ItemGroup>
         <Compile Include="Extensions.fs"/>
         <Compile Include="NewStreamMessage.fs"/>
@@ -32,4 +24,12 @@
         <Compile Include="Create.fs"/>
     </ItemGroup>
 
+    <ItemGroup>
+        <PackageReference Update="FSharp.Core" Version="6.0.*"/>
+        <PackageReference Include="FSharp.Core" Version="6.0.*"/>
+        <PackageReference Include="FSharp.Prelude" Version="5.0.*"/>
+        <PackageReference Include="Npgsql" Version="5.0.*"/>
+        <PackageReference Include="SqlStreamStore" Version="1.2.0-beta.8"/>
+    </ItemGroup>
+
 </Project>

src/SqlStreamStore.FSharp/Subscribe.fs

@@ -1,6 +1,6 @@
 namespace SqlStreamStore.FSharp
 
-open FSharp.Prelude
+open Prelude.ErrorHandling
 open SqlStreamStore
 open SqlStreamStore.Streams
 open SqlStreamStore.Subscriptions
@@ -36,7 +36,7 @@ module Subscribe =
         let mutable subscriptionDropped = null
 
         let streamMessageReceived' =
-            let subs : IStreamSubscription -> StreamMessage -> CancellationToken -> Task =
+            let subs: IStreamSubscription -> StreamMessage -> CancellationToken -> Task =
                 fun iStreamSubscription msg cancellationToken ->
                     streamMessageReceived iStreamSubscription msg cancellationToken
                     |> Async.StartImmediateAsTask
@@ -86,7 +86,7 @@ module Subscribe =
         let mutable subscriptionDropped = null
 
         let streamMessageReceived' =
-            let subs : IAllStreamSubscription -> StreamMessage -> CancellationToken -> Task =
+            let subs: IAllStreamSubscription -> StreamMessage -> CancellationToken -> Task =
                 fun iAllStreamSubscription msg cancellationToken ->
                     streamMessageReceived iAllStreamSubscription msg cancellationToken
                     |> Async.StartImmediateAsTask