cleanup

Author: Baccata

fs2/src/jsonrpclib/fs2/FS2Channel.scala

@@ -46,7 +46,7 @@ object FS2Channel {
     val endpointsMap = startingEndpoints.map(ep => ep.method -> ep).toMap
     for {
       supervisor <- Stream.resource(Supervisor[F])
-      ref <- Ref[F].of(State[F](Map.empty, endpointsMap, 0, false)).toStream
+      ref <- Ref[F].of(State[F](Map.empty, endpointsMap, 0)).toStream
       isOpen <- SignallingRef[F].of(false).toStream
       awaitingSink = isOpen.waitUntil(identity) >> payloadSink(_: Payload)
       impl = new Impl(awaitingSink, ref, isOpen, supervisor)
@@ -61,8 +61,7 @@ object FS2Channel {
   private case class State[F[_]](
       pendingCalls: Map[CallId, OutputMessage => F[Unit]],
       endpoints: Map[String, Endpoint[F]],
-      counter: Long,
-      isOpen: Boolean
+      counter: Long
   ) {
     def nextCallId: (State[F], CallId) = (this.copy(counter = counter + 1), CallId.NumberId(counter))
     def storePendingCall(callId: CallId, handle: OutputMessage => F[Unit]): State[F] =
@@ -78,9 +77,6 @@ object FS2Channel {
       }
     def removeEndpoint(method: String): State[F] =
       copy(endpoints = endpoints.removed(method))
-
-    def open: State[F] = copy(isOpen = true)
-    def close: State[F] = copy(isOpen = false)
   }
 
   private class Impl[F[_]](