Skip to content

Commit a5da691

Browse files
jamil7jamil7
authored
Upgrade (#19)
1 parent 2651f6a commit a5da691

File tree

8 files changed

+26
-24
lines changed

8 files changed

+26
-24
lines changed

‎src/SqlStreamStore.FSharp.Postgres/Create.fs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
namespace SqlStreamStore.FSharp.Postgres
22

3-
open FSharp.Prelude
3+
open Prelude.ErrorHandling
44
open SqlStreamStore
55

66
type PostgresConfig =

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,8 @@
1616
</ItemGroup>
1717

1818
<ItemGroup>
19+
<PackageReference Update="FSharp.Core" Version="6.0.*"/>
20+
<PackageReference Include="FSharp.Core" Version="6.0.*"/>
1921
<PackageReference Include="SqlStreamStore.Postgres" Version="1.2.0-beta.8"/>
2022
</ItemGroup>
2123

‎src/SqlStreamStore.FSharp/Append.fs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
namespace SqlStreamStore.FSharp
22

3-
open FSharp.Prelude
3+
open Prelude.ErrorHandling
44
open System.Threading
55
open SqlStreamStore
66

‎src/SqlStreamStore.FSharp/Extensions.fs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
namespace SqlStreamStore.FSharp
22

33
open System.Threading
4-
open FSharp.Prelude
4+
open Prelude.ErrorHandling
55
open SqlStreamStore
66
open SqlStreamStore.Streams
77
open System

‎src/SqlStreamStore.FSharp/Get.fs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,12 @@
11
namespace SqlStreamStore.FSharp
22

3-
open FSharp.Prelude
3+
open Prelude.ErrorHandling
44
open SqlStreamStore.Streams
55

66
module Get =
77

88
// A function to help wit type inference in this module
9-
let private curriedMap : (ReadStreamPage -> 'a) -> AsyncResult<ReadStreamPage, exn> -> AsyncResult<'a, exn> =
9+
let private curriedMap: (ReadStreamPage -> 'a) -> AsyncResult<ReadStreamPage, exn> -> AsyncResult<'a, exn> =
1010
AsyncResult.map
1111

1212
let messages =
@@ -44,7 +44,7 @@ module Get =
4444
module GetAll =
4545

4646
// A function to help wit type inference in this module
47-
let private curriedMap : (ReadAllPage -> 'a) -> AsyncResult<ReadAllPage, exn> -> AsyncResult<'a, exn> =
47+
let private curriedMap: (ReadAllPage -> 'a) -> AsyncResult<ReadAllPage, exn> -> AsyncResult<'a, exn> =
4848
AsyncResult.map
4949

5050
let messages =

‎src/SqlStreamStore.FSharp/Read.fs

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
namespace SqlStreamStore.FSharp
22

3-
open FSharp.Prelude
3+
open Prelude.ErrorHandling
44
open System.Threading
55
open SqlStreamStore
66
open SqlStreamStore.Streams
@@ -36,7 +36,7 @@ module Read =
3636
let partial' (readOptions: ReadPartialOption list) (Stream stream: Stream) : AsyncResult<ReadStreamPage, exn> =
3737

3838
let mutable cancellationToken = Unchecked.defaultof<CancellationToken>
39-
let mutable fromVersionInclusive : int option = None
39+
let mutable fromVersionInclusive: int option = None
4040
let mutable messageCount = 1000
4141
let mutable prefetch = true
4242
let mutable readDirection = ReadDirection.Forward
@@ -79,12 +79,12 @@ module Read =
7979
)
8080
| _ -> failwith "Illegal ReadDirection enum."
8181

82-
let partial : Stream -> AsyncResult<ReadStreamPage, exn> = partial' []
82+
let partial: Stream -> AsyncResult<ReadStreamPage, exn> = partial' []
8383

8484
let entire' (readOptions: ReadEntireOption list) : Stream -> AsyncResult<ReadStreamPage, exn> =
8585

8686
let mutable cancellationToken = Unchecked.defaultof<CancellationToken>
87-
let mutable fromVersionInclusive : int option = None
87+
let mutable fromVersionInclusive: int option = None
8888
let mutable prefetch = true
8989
let mutable readDirection = ReadDirection.Forward
9090

@@ -119,12 +119,12 @@ module Read =
119119

120120
partial' (options @ options')
121121

122-
let entire : Stream -> AsyncResult<ReadStreamPage, exn> = entire' []
122+
let entire: Stream -> AsyncResult<ReadStreamPage, exn> = entire' []
123123

124124
let allStream' (readOptions: ReadAllOption list) : IStreamStore -> AsyncResult<ReadAllPage, exn> =
125125

126126
let mutable cancellationToken = Unchecked.defaultof<CancellationToken>
127-
let mutable fromPositionInclusive : int64 option = None
127+
let mutable fromPositionInclusive: int64 option = None
128128
let mutable messageCount = 1000
129129
let mutable prefetch = true
130130
let mutable readDirection = ReadDirection.Forward
@@ -165,4 +165,4 @@ module Read =
165165
)
166166
| _ -> failwith "Illegal ReadDirection enum."
167167

168-
let allStream : IStreamStore -> AsyncResult<ReadAllPage, exn> = allStream' []
168+
let allStream: IStreamStore -> AsyncResult<ReadAllPage, exn> = allStream' []

‎src/SqlStreamStore.FSharp/SqlStreamStore.FSharp.fsproj

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -13,14 +13,6 @@
1313
<OtherFlags>$(OtherFlags) --warnon:1182</OtherFlags>
1414
</PropertyGroup>
1515

16-
<ItemGroup>
17-
<PackageReference Update="FSharp.Core" Version="5.0.0"/>
18-
<PackageReference Include="FSharp.Core" Version="5.0.0"/>
19-
<PackageReference Include="FSharp.Prelude" Version="4.0.*"/>
20-
<PackageReference Include="Npgsql" Version="5.0.*"/>
21-
<PackageReference Include="SqlStreamStore" Version="1.2.0-beta.8"/>
22-
</ItemGroup>
23-
2416
<ItemGroup>
2517
<Compile Include="Extensions.fs"/>
2618
<Compile Include="NewStreamMessage.fs"/>
@@ -32,4 +24,12 @@
3224
<Compile Include="Create.fs"/>
3325
</ItemGroup>
3426

27+
<ItemGroup>
28+
<PackageReference Update="FSharp.Core" Version="6.0.*"/>
29+
<PackageReference Include="FSharp.Core" Version="6.0.*"/>
30+
<PackageReference Include="FSharp.Prelude" Version="5.0.*"/>
31+
<PackageReference Include="Npgsql" Version="5.0.*"/>
32+
<PackageReference Include="SqlStreamStore" Version="1.2.0-beta.8"/>
33+
</ItemGroup>
34+
3535
</Project>

‎src/SqlStreamStore.FSharp/Subscribe.fs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
namespace SqlStreamStore.FSharp
22

3-
open FSharp.Prelude
3+
open Prelude.ErrorHandling
44
open SqlStreamStore
55
open SqlStreamStore.Streams
66
open SqlStreamStore.Subscriptions
@@ -36,7 +36,7 @@ module Subscribe =
3636
let mutable subscriptionDropped = null
3737

3838
let streamMessageReceived' =
39-
let subs : IStreamSubscription -> StreamMessage -> CancellationToken -> Task =
39+
let subs: IStreamSubscription -> StreamMessage -> CancellationToken -> Task =
4040
fun iStreamSubscription msg cancellationToken ->
4141
streamMessageReceived iStreamSubscription msg cancellationToken
4242
|> Async.StartImmediateAsTask
@@ -86,7 +86,7 @@ module Subscribe =
8686
let mutable subscriptionDropped = null
8787

8888
let streamMessageReceived' =
89-
let subs : IAllStreamSubscription -> StreamMessage -> CancellationToken -> Task =
89+
let subs: IAllStreamSubscription -> StreamMessage -> CancellationToken -> Task =
9090
fun iAllStreamSubscription msg cancellationToken ->
9191
streamMessageReceived iAllStreamSubscription msg cancellationToken
9292
|> Async.StartImmediateAsTask

0 commit comments

Comments
 (0)