Remove starting endpoints

Author: Baccata

fs2/src/jsonrpclib/fs2/FS2Channel.scala

@@ -32,21 +32,18 @@ object FS2Channel {
  def lspCompliant[F[_]: Concurrent](
  byteStream: Stream[F, Byte],
  byteSink: Pipe[F, Byte, Nothing],
- startingEndpoints: List[Endpoint[F]] = List.empty,
  bufferSize: Int = 512
  ): Stream[F, FS2Channel[F]] = internals.LSP.writeSink(byteSink, bufferSize).flatMap { sink =>
- apply[F](internals.LSP.readStream(byteStream), sink, startingEndpoints)
+ apply[F](internals.LSP.readStream(byteStream), sink)
  }
 
  def apply[F[_]: Concurrent](
  payloadStream: Stream[F, Payload],
- payloadSink: Payload => F[Unit],
- startingEndpoints: List[Endpoint[F]] = List.empty[Endpoint[F]]
+ payloadSink: Payload => F[Unit]
  ): Stream[F, FS2Channel[F]] = {
- 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)).toStream
+ ref <- Ref[F].of(State[F](Map.empty, Map.empty, 0)).toStream
  isOpen <- SignallingRef[F].of(false).toStream
  awaitingSink = isOpen.waitUntil(identity) >> payloadSink(_: Payload)
  impl = new Impl(awaitingSink, ref, isOpen, supervisor)