2.12 build

7mind · Nov 8, 2023 · c618250 · c618250
1 parent bc4fa44
commit c618250
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/...s/src/main/scala/izumi/idealingua/runtime/rpc/http4s/clients/WsRpcDispatcherFactory.scala b/...s/src/main/scala/izumi/idealingua/runtime/rpc/http4s/clients/WsRpcDispatcherFactory.scala
@@ -88,6 +88,7 @@ class WsRpcDispatcherFactory[F[+_, +_]: Async2: Temporal2: Primitives2: UnsafeRu
     override def onClose(websocket: WebSocket, code: Int, reason: String): Unit = {
       socketRef.set(None)
       websocket.sendCloseFrame()
+      ()
     }
 
     override def onError(t: Throwable): Unit = {

diff --git a/...ime-rpc-http4s/src/main/scala/izumi/idealingua/runtime/rpc/http4s/ws/WsRequestState.scala b/...ime-rpc-http4s/src/main/scala/izumi/idealingua/runtime/rpc/http4s/ws/WsRequestState.scala
@@ -81,7 +81,7 @@ class WsRequestState[F[+_, +_]: IO2: Temporal2: Primitives2] extends WsClientRes
         responses.values().removeIf {
           handler =>
             val isExpired = handler.expired(now)
-            if (isExpired) removed.addOne(handler)
+            if (isExpired) removed.append(handler)
             isExpired
         }
         removed.toList