Add HttpClientFs2Backend.resourceUsingClient.

softwaremill · Nov 8, 2022 · 618b130 · 618b130
1 parent edc6f4d
commit 618b130
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/effects/fs2/src/main/scalajvm/sttp/client3/httpclient/fs2/HttpClientFs2Backend.scala b/effects/fs2/src/main/scalajvm/sttp/client3/httpclient/fs2/HttpClientFs2Backend.scala
@@ -132,6 +132,17 @@ object HttpClientFs2Backend {
       Resource.make(apply(dispatcher, options, customizeRequest, customEncodingHandler))(_.close())
     )
 
+  def resourceUsingClient[F[_]: Async](
+      client: HttpClient,
+      customizeRequest: HttpRequest => HttpRequest = identity,
+      customEncodingHandler: Fs2EncodingHandler[F] = PartialFunction.empty
+  ): Resource[F, SttpBackend[F, Fs2Streams[F] with WebSockets]] =
+    Dispatcher[F].flatMap(dispatcher =>
+      Resource.make(
+        Sync[F].delay(apply(client, closeClient = true, customizeRequest, customEncodingHandler, dispatcher))
+      )(_.close())
+    )
+
   def usingClient[F[_]: Async](
       client: HttpClient,
       dispatcher: Dispatcher[F],