Renaming "handler" to "backend"

1 files changed, 0 insertions, 112 deletions

diff --git a/async-http-client-handler/fs2/src/main/scala/com/softwaremill/sttp/asynchttpclient/fs2/AsyncHttpClientFs2Handler.scala b/async-http-client-handler/fs2/src/main/scala/com/softwaremill/sttp/asynchttpclient/fs2/AsyncHttpClientFs2Handler.scala
deleted file mode 100644
index 1462951..0000000
--- a/async-http-client-handler/fs2/src/main/scala/com/softwaremill/sttp/asynchttpclient/fs2/AsyncHttpClientFs2Handler.scala
+++ /dev/null
@@ -1,112 +0,0 @@
-package com.softwaremill.sttp.asynchttpclient.fs2
-
-import java.nio.ByteBuffer
-
-import cats.effect._
-import com.softwaremill.sttp.asynchttpclient.AsyncHttpClientHandler
-import com.softwaremill.sttp.{
-  FollowRedirectsHandler,
-  MonadAsyncError,
-  SttpHandler,
-  Utf8,
-  concatByteBuffers
-}
-import fs2._
-import fs2.interop.reactivestreams._
-import org.asynchttpclient.{
-  AsyncHttpClient,
-  AsyncHttpClientConfig,
-  DefaultAsyncHttpClient
-}
-import org.reactivestreams.Publisher
-
-import scala.concurrent.ExecutionContext
-import scala.concurrent.duration.FiniteDuration
-import scala.language.higherKinds
-
-class AsyncHttpClientFs2Handler[F[_]: Effect] private (
-    asyncHttpClient: AsyncHttpClient,
-    closeClient: Boolean)(implicit ec: ExecutionContext)
-    extends AsyncHttpClientHandler[F, Stream[F, ByteBuffer]](
-      asyncHttpClient,
-      new EffectMonad,
-      closeClient
-    ) {
-
-  override protected def streamBodyToPublisher(
-      s: Stream[F, ByteBuffer]): Publisher[ByteBuffer] =
-    s.toUnicastPublisher
-
-  override protected def publisherToStreamBody(
-      p: Publisher[ByteBuffer]): Stream[F, ByteBuffer] =
-    p.toStream[F]
-
-  override protected def publisherToString(
-      p: Publisher[ByteBuffer]): F[String] = {
-    val bytes = p
-      .toStream[F]
-      .runFold(ByteBuffer.allocate(0))(concatByteBuffers)
-
-    implicitly[Effect[F]].map(bytes)(bb => new String(bb.array(), Utf8))
-  }
-}
-
-object AsyncHttpClientFs2Handler {
-
-  private def apply[F[_]: Effect](asyncHttpClient: AsyncHttpClient,
-                                  closeClient: Boolean)(
-      implicit ec: ExecutionContext): SttpHandler[F, Stream[F, ByteBuffer]] =
-    new FollowRedirectsHandler(
-      new AsyncHttpClientFs2Handler(asyncHttpClient, closeClient))
-
-  /**
-    * @param ec The execution context for running non-network related operations,
-    *           e.g. mapping responses. Defaults to the global execution
-    *           context.
-    */
-  def apply[F[_]: Effect](connectionTimeout: FiniteDuration =
-                            SttpHandler.DefaultConnectionTimeout)(
-      implicit ec: ExecutionContext = ExecutionContext.Implicits.global)
-    : SttpHandler[F, Stream[F, ByteBuffer]] =
-    AsyncHttpClientFs2Handler[F](
-      AsyncHttpClientHandler.defaultClient(connectionTimeout.toMillis.toInt),
-      closeClient = true)
-
-  /**
-    * @param ec The execution context for running non-network related operations,
-    *           e.g. mapping responses. Defaults to the global execution
-    *           context.
-    */
-  def usingConfig[F[_]: Effect](cfg: AsyncHttpClientConfig)(
-      implicit ec: ExecutionContext = ExecutionContext.Implicits.global)
-    : SttpHandler[F, Stream[F, ByteBuffer]] =
-    AsyncHttpClientFs2Handler[F](new DefaultAsyncHttpClient(cfg),
-                                 closeClient = true)
-
-  /**
-    * @param ec The execution context for running non-network related operations,
-    *           e.g. mapping responses. Defaults to the global execution
-    *           context.
-    */
-  def usingClient[F[_]: Effect](client: AsyncHttpClient)(
-      implicit ec: ExecutionContext = ExecutionContext.Implicits.global)
-    : SttpHandler[F, Stream[F, ByteBuffer]] =
-    AsyncHttpClientFs2Handler[F](client, closeClient = false)
-}
-
-private[fs2] class EffectMonad[F[_]](implicit F: Effect[F])
-    extends MonadAsyncError[F] {
-
-  override def async[T](
-      register: ((Either[Throwable, T]) => Unit) => Unit): F[T] =
-    F.async(register)
-
-  override def unit[T](t: T): F[T] = F.pure(t)
-
-  override def map[T, T2](fa: F[T])(f: (T) => T2): F[T2] = F.map(fa)(f)
-
-  override def flatMap[T, T2](fa: F[T])(f: (T) => F[T2]): F[T2] =
-    F.flatMap(fa)(f)
-
-  override def error[T](t: Throwable): F[T] = F.raiseError(t)
-}