Fixed warnings introduced by Scala 3 upgrade

Author: mpilquist

core/shared/src/main/scala-3/fs2/ChunkPlatform.scala

@@ -24,7 +24,6 @@ package fs2
 import scodec.bits.ByteVector
 
 import scala.collection.immutable.ArraySeq
-import scala.collection.immutable
 import scala.reflect.ClassTag
 
 private[fs2] trait ChunkPlatform[+O] extends Chunk213And3Compat[O] {

core/shared/src/main/scala/fs2/Stream.scala

@@ -3816,6 +3816,7 @@ object Stream extends StreamLowPriority {
     * are dequeued and emitted as a single chunk.
     */
   @nowarn("msg=never used")
+  @nowarn3("msg=unused implicit parameter")
   def fromQueueNoneTerminated[F[_]: Functor, A](
       queue: QueueSource[F, Option[A]],
       limit: Int = Int.MaxValue

io/js/src/main/scala/fs2/io/internal/facade/net.scala

@@ -82,7 +82,7 @@ private[io] object net {
   @js.native
   class Socket extends fs2.io.Duplex {
 
-    def this(options: SocketOptions) = this()
+    def this(@unused options: SocketOptions) = this()
 
     def connect(path: String, connectListener: js.Function0[Unit]): Socket = js.native
 

io/js/src/main/scala/fs2/io/internal/facade/tls.scala

@@ -183,7 +183,7 @@ private[io] object tls {
   @js.native
   class TLSSocket extends Socket {
 
-    def this(socket: fs2.io.Duplex, options: TLSSocketOptions) = this()
+    def this(@unused socket: fs2.io.Duplex, @unused options: TLSSocketOptions) = this()
 
     def alpnProtocol: String | Boolean = js.native
 

io/js/src/main/scala/fs2/io/ioplatform.scala

@@ -32,10 +32,11 @@ import fs2.io.internal.facade
 
 import java.nio.charset.Charset
 import java.nio.charset.StandardCharsets
-import scala.annotation.nowarn
 import scala.scalajs.js
 import scala.scalajs.js.typedarray.Uint8Array
 
+import org.typelevel.scalaccompat.annotation._
+
 private[fs2] trait ioplatform {
 
   @deprecated("Use suspendReadableAndRead instead", "3.1.4")
@@ -423,8 +424,7 @@ private[fs2] trait ioplatform {
   /** Stream of bytes read asynchronously from standard input.
     * Takes a dummy `Int` parameter for source-compatibility with JVM.
     */
-  @nowarn("msg=never used")
-  def stdin[F[_]: Async](ignored: Int): Stream[F, Byte] = stdin
+  def stdin[F[_]: Async](@unused ignored: Int): Stream[F, Byte] = stdin
 
   /** Pipe of bytes that writes emitted values to standard output asynchronously. */
   def stdout[F[_]: Async]: Pipe[F, Byte, Nothing] = stdoutAsync
@@ -451,8 +451,7 @@ private[fs2] trait ioplatform {
   /** Stream of `String` read asynchronously from standard input decoded in UTF-8.
     * Takes a dummy `Int` parameter for source-compatibility with JVM.
     */
-  @nowarn("msg=never used")
-  def stdinUtf8[F[_]: Async](ignored: Int): Stream[F, String] =
+  def stdinUtf8[F[_]: Async](@unused ignored: Int): Stream[F, String] =
     stdinAsync.through(text.utf8.decode)
 
   // Copied JVM implementations, for bincompat

io/jvm/src/main/scala/fs2/io/net/AsynchronousDatagramSocketGroup.scala

@@ -178,11 +178,11 @@ private[net] object AsynchronousDatagramSocketGroup {
 
         onSelectorThread {
           val channel = key.channel.asInstanceOf[DatagramChannel]
-          var cancelReader: () => Unit = null
           if (attachment.hasReaders) {
-            cancelReader = attachment.queueReader(readerId, cb)
+            attachment.queueReader(readerId, cb)
+            ()
           } else if (!read1(channel, cb)) {
-            cancelReader = attachment.queueReader(readerId, cb)
+            attachment.queueReader(readerId, cb)
             try {
               key.interestOps(key.interestOps | SelectionKey.OP_READ); ()
             } catch {
@@ -239,11 +239,10 @@ private[net] object AsynchronousDatagramSocketGroup {
         val attachment = key.attachment.asInstanceOf[Attachment]
         onSelectorThread {
           val channel = key.channel.asInstanceOf[DatagramChannel]
-          var cancelWriter: () => Unit = null
           if (attachment.hasWriters) {
-            cancelWriter = attachment.queueWriter(writerId, (writerDatagram, cb))
+            attachment.queueWriter(writerId, (writerDatagram, cb))
+            ()
           } else if (!write1(channel, writerDatagram, cb)) {
-            cancelWriter = attachment.queueWriter(writerId, (writerDatagram, cb))
             try {
               key.interestOps(key.interestOps | SelectionKey.OP_WRITE); ()
             } catch {

protocols/shared/src/main/scala/fs2/protocols/ip/Ipv4Header.scala

@@ -24,13 +24,13 @@
 package fs2.protocols
 package ip
 
-import scodec.bits._
+import scodec.bits.*
 import scodec.{Codec, SizeBound}
-import scodec.codecs._
-import scodec.compat._
-import fs2.interop.scodec._
+import scodec.codecs.*
+import fs2.interop.scodec.*
 import fs2.protocols.ethernet.{EtherType, EthernetFrameHeader}
 import com.comcast.ip4s.Ipv4Address
+import org.typelevel.scalaccompat.annotation.*
 
 /** IPv4 header. */
 case class Ipv4Header(
@@ -43,7 +43,9 @@ case class Ipv4Header(
     options: BitVector
 ) extends UnsealedIpHeader
 
+@nowarn3("msg=unused import")
 object Ipv4Header {
+  import scodec.compat.*
 
   implicit val codec: Codec[Ipv4Header] = {
     // format: off

protocols/shared/src/main/scala/fs2/protocols/mpeg/PesPacketHeader.scala

@@ -23,10 +23,10 @@
 
 package fs2.protocols.mpeg
 
-import scodec.bits._
+import scodec.bits.*
 import scodec.Codec
-import scodec.codecs._
-import scodec.compat._
+import scodec.codecs.*
+import org.typelevel.scalaccompat.annotation.*
 
 sealed abstract class PesScramblingControl
 object PesScramblingControl {
@@ -61,7 +61,9 @@ case class PesPacketHeader(
     extension: Option[PesPacketHeader.Extension]
 )
 
+@nowarn3("msg=unused import")
 object PesPacketHeader {
+  import scodec.compat.*
 
   case class Flags(
       ptsFlag: Boolean,

protocols/shared/src/main/scala/fs2/protocols/mpeg/transport/AdaptationField.scala

@@ -26,8 +26,8 @@ package transport
 
 import scodec.{Attempt, Codec, DecodeResult, SizeBound}
 import scodec.bits.BitVector
-import scodec.codecs._
-import scodec.compat._
+import scodec.codecs.*
+import org.typelevel.scalaccompat.annotation.*
 
 /** Partial modelling of the adaptation field.
   * The field extension, if present, is ignored upon decoding.
@@ -40,7 +40,9 @@ case class AdaptationField(
     transportPrivateData: Option[BitVector]
 )
 
+@nowarn3("msg=unused import")
 object AdaptationField {
+  import scodec.compat.*
 
   final val Empty: AdaptationField = AdaptationField(None, None, None, None, None)
 

reactive-streams/src/main/scala/fs2/interop/reactivestreams/StreamUnicastPublisher.scala

@@ -28,6 +28,7 @@ import cats.effect.std.Dispatcher
 
 import org.reactivestreams._
 
+import scala.annotation.unused
 import scala.util.control.NoStackTrace
 
 /** Implementation of a `org.reactivestreams.Publisher`
@@ -49,7 +50,7 @@ final class StreamUnicastPublisher[F[_]: Async, A](
   private[reactivestreams] def this(
       stream: Stream[F, A],
       startDispatcher: Dispatcher[F],
-      requestDispatcher: Dispatcher[F]
+      @unused requestDispatcher: Dispatcher[F]
   ) =
     this(stream, startDispatcher)