@@ -4,8 +4,6 @@ import caliban.client.Operations.IsOperation
4
4
import caliban .client .SelectionBuilder
5
5
import com .devsisters .shardcake .internal .GraphQLClient
6
6
import com .devsisters .shardcake .internal .GraphQLClient .PodAddressInput
7
- import sttp .capabilities .WebSockets
8
- import sttp .capabilities .zio .ZioStreams
9
7
import sttp .client3 .SttpBackend
10
8
import sttp .client3 .asynchttpclient .zio .AsyncHttpClientZioBackend
11
9
import zio .{ Config => _ , _ }
@@ -26,10 +24,10 @@ object ShardManagerClient {
26
24
* A layer that returns a client for the Shard Manager API.
27
25
* It requires an sttp backend. If you don't want to use your own backend, simply use `liveWithSttp`.
28
26
*/
29
- val live : ZLayer [Config with SttpBackend [Task , ZioStreams with WebSockets ], Nothing , ShardManagerClientLive ] =
27
+ val live : ZLayer [Config with SttpBackend [Task , Any ], Nothing , ShardManagerClientLive ] =
30
28
ZLayer {
31
29
for {
32
- sttpClient <- ZIO .service[SttpBackend [Task , ZioStreams with WebSockets ]]
30
+ sttpClient <- ZIO .service[SttpBackend [Task , Any ]]
33
31
config <- ZIO .service[Config ]
34
32
} yield new ShardManagerClientLive (sttpClient, config)
35
33
}
@@ -58,10 +56,7 @@ object ShardManagerClient {
58
56
}
59
57
}
60
58
61
- class ShardManagerClientLive (
62
- sttp : SttpBackend [Task , ZioStreams with WebSockets ],
63
- config : Config
64
- ) extends ShardManagerClient {
59
+ class ShardManagerClientLive (sttp : SttpBackend [Task , Any ], config : Config ) extends ShardManagerClient {
65
60
private def send [Origin : IsOperation , A ](query : SelectionBuilder [Origin , A ]): Task [A ] =
66
61
sttp.send(query.toRequest(config.shardManagerUri)).map(_.body).absolve
67
62
0 commit comments