From ddd3e62ed92a2d6a3e533b08b4341d8bdf5888a8 Mon Sep 17 00:00:00 2001
From: Tomasz Godzik <tgodzik@virtuslab.com>
Date: Fri, 30 Jun 2023 14:21:34 +0200
Subject: [PATCH] refactor: Remove unused class

---
 .../src/main/scala/bloop/bsp/BspServer.scala  | 35 -------------------
 1 file changed, 35 deletions(-)

diff --git a/frontend/src/main/scala/bloop/bsp/BspServer.scala b/frontend/src/main/scala/bloop/bsp/BspServer.scala
index 84c1e791b0..2c042df4cc 100644
--- a/frontend/src/main/scala/bloop/bsp/BspServer.scala
+++ b/frontend/src/main/scala/bloop/bsp/BspServer.scala
@@ -6,7 +6,6 @@ import java.nio.file.NoSuchFileException
 import java.util.concurrent.ConcurrentHashMap
 import java.util.concurrent.TimeUnit
 
-import scala.concurrent.Future
 import scala.concurrent.Promise
 import scala.util.control.NonFatal
 
@@ -22,15 +21,11 @@ import bloop.logging.DebugFilter
 import bloop.task.Task
 
 import jsonrpc4s._
-import monix.execution.Ack
-import monix.execution.Cancelable
 import monix.execution.CancelablePromise
 import monix.execution.Scheduler
 import monix.execution.atomic.Atomic
 import monix.reactive.Observable
-import monix.reactive.Observer
 import monix.reactive.OverflowStrategy
-import monix.reactive.observers.Subscriber
 import monix.reactive.subjects.BehaviorSubject
 
 object BspServer {
@@ -216,34 +211,4 @@ object BspServer {
     }
   }
 
-  final class PumpOperator[A](pumpTarget: Observer.Sync[A], runningFuture: Cancelable)
-      extends Observable.Operator[A, A] {
-    def apply(out: Subscriber[A]): Subscriber[A] =
-      new Subscriber[A] { self =>
-        implicit val scheduler = out.scheduler
-        private[this] val isActive = Atomic(true)
-
-        def onNext(elem: A): Future[Ack] =
-          out.onNext(elem).syncOnContinue {
-            // Forward and ignore ack; safe because observer is sync
-            pumpTarget.onNext(elem)
-            ()
-          }
-
-        def onComplete(): Unit = {
-          if (isActive.getAndSet(false))
-            out.onComplete()
-        }
-
-        def onError(ex: Throwable): Unit = {
-          if (isActive.getAndSet(false)) {
-            // Complete instead of forwarding error so that completeL finishes
-            out.onComplete()
-            runningFuture.cancel()
-          } else {
-            scheduler.reportFailure(ex)
-          }
-        }
-      }
-  }
 }