@@ -19,24 +19,38 @@ private[http4s] trait Http4sBackendCompanion {
1919
2020 def usingClient [F [_]: Async ](
2121 client : Client [F ],
22- customizeRequest : Http4sRequest [F ] => Http4sRequest [F ] = identity[Http4sRequest [F ]] _,
23- compressionHandlers : Async [F ] => CompressionHandlers [Fs2Streams [F ], EntityBody [F ]] =
24- defaultCompressionHandlers[F ](_ : Async [F ])
22+ customizeRequest : Http4sRequest [F ] => Http4sRequest [F ] = identity[Http4sRequest [F ]] _
23+ ): StreamBackend [F , Fs2Streams [F ]] =
24+ usingClient(client, customizeRequest, async => defaultCompressionHandlers[F ](using async))
25+
26+ def usingClient [F [_]: Async ](
27+ client : Client [F ],
28+ customizeRequest : Http4sRequest [F ] => Http4sRequest [F ],
29+ compressionHandlers : Async [F ] => CompressionHandlers [Fs2Streams [F ], EntityBody [F ]]
2530 ): StreamBackend [F , Fs2Streams [F ]] =
2631 FollowRedirectsBackend (new Http4sBackend [F ](client, customizeRequest, compressionHandlers(implicitly)))
2732
2833 def usingEmberClientBuilder [F [_]: Async : Network ](
2934 emberClientBuilder : EmberClientBuilder [F ],
30- customizeRequest : Http4sRequest [F ] => Http4sRequest [F ] = identity[Http4sRequest [F ]] _,
31- compressionHandlers : Async [F ] => CompressionHandlers [Fs2Streams [F ], EntityBody [F ]] =
32- defaultCompressionHandlers[F ](_ : Async [F ])
35+ customizeRequest : Http4sRequest [F ] => Http4sRequest [F ] = identity[Http4sRequest [F ]] _
36+ ): Resource [F , StreamBackend [F , Fs2Streams [F ]]] =
37+ usingEmberClientBuilder(emberClientBuilder, customizeRequest, async => defaultCompressionHandlers[F ](using async))
38+
39+ def usingEmberClientBuilder [F [_]: Async : Network ](
40+ emberClientBuilder : EmberClientBuilder [F ],
41+ customizeRequest : Http4sRequest [F ] => Http4sRequest [F ],
42+ compressionHandlers : Async [F ] => CompressionHandlers [Fs2Streams [F ], EntityBody [F ]]
3343 ): Resource [F , StreamBackend [F , Fs2Streams [F ]]] =
3444 emberClientBuilder.build.map(c => usingClient(c, customizeRequest, compressionHandlers))
3545
3646 def usingDefaultEmberClientBuilder [F [_]: Async : Network ](
37- customizeRequest : Http4sRequest [F ] => Http4sRequest [F ] = identity[Http4sRequest [F ]] _,
38- compressionHandlers : Async [F ] => CompressionHandlers [Fs2Streams [F ], EntityBody [F ]] =
39- defaultCompressionHandlers[F ](_ : Async [F ])
47+ customizeRequest : Http4sRequest [F ] => Http4sRequest [F ] = identity[Http4sRequest [F ]] _
48+ ): Resource [F , StreamBackend [F , Fs2Streams [F ]]] =
49+ usingDefaultEmberClientBuilder(customizeRequest, async => defaultCompressionHandlers[F ](using async))
50+
51+ def usingDefaultEmberClientBuilder [F [_]: Async : Network ](
52+ customizeRequest : Http4sRequest [F ] => Http4sRequest [F ],
53+ compressionHandlers : Async [F ] => CompressionHandlers [Fs2Streams [F ], EntityBody [F ]]
4054 ): Resource [F , StreamBackend [F , Fs2Streams [F ]]] =
4155 usingEmberClientBuilder(EmberClientBuilder .default[F ], customizeRequest, compressionHandlers)
4256
0 commit comments