removed chunksize from transferto and transferfrom

Author: rahulrangers

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

@@ -91,8 +91,7 @@ private final class SelectingSocket[F[_]: LiftIO] private (
       def go(currOffset: Long, remaining: Long): F[Unit] =
         if (remaining <= 0) F.unit
         else {
-          val toTransfer = remaining.min(chunkSize.toLong)
-          F.blocking(fileChannel.transferTo(currOffset, toTransfer, ch)).flatMap { written =>
+          F.blocking(fileChannel.transferTo(currOffset, remaining, ch)).flatMap { written =>
             if (written > 0) {
               go(currOffset + written, remaining - written)
             } else {
@@ -119,8 +118,7 @@ private final class SelectingSocket[F[_]: LiftIO] private (
       def go(currOffset: Long, remaining: Long): F[Unit] =
         if (remaining <= 0) F.unit
         else {
-          val toTransfer = remaining.min(chunkSize.toLong)
-          F.blocking(fileChannel.transferFrom(ch, currOffset, toTransfer)).flatMap { readBytes =>
+          F.blocking(fileChannel.transferFrom(ch, currOffset, remaining)).flatMap { readBytes =>
             if (readBytes > 0) {
               go(currOffset + readBytes, remaining - readBytes)
             } else {

io/jvm/src/main/scala/fs2/io/net/unixsocket/UnixSocketsPlatform.scala

@@ -150,8 +150,7 @@ private[unixsocket] trait UnixSocketsCompanionPlatform {
         def go(currOffset: Long, remaining: Long): F[Unit] =
           if (remaining <= 0) F.unit
           else {
-            val toTransfer = remaining.min(chunkSize.toLong)
-            F.blocking(fileChannel.transferTo(currOffset, toTransfer, ch)).flatMap { written =>
+            F.blocking(fileChannel.transferTo(currOffset, remaining, ch)).flatMap { written =>
               if (written == 0) F.unit
               else {
                 go(currOffset + written, remaining - written)
@@ -177,8 +176,7 @@ private[unixsocket] trait UnixSocketsCompanionPlatform {
         def go(currOffset: Long, remaining: Long): F[Unit] =
           if (remaining <= 0) F.unit
           else {
-            val toTransfer = remaining.min(chunkSize.toLong)
-            F.blocking(fileChannel.transferFrom(ch, currOffset, toTransfer)).flatMap { readBytes =>
+            F.blocking(fileChannel.transferFrom(ch, currOffset, remaining)).flatMap { readBytes =>
               if (readBytes == 0) F.unit
               else {
                 go(currOffset + readBytes, remaining - readBytes)

io/shared/src/main/scala/fs2/io/net/Socket.scala

@@ -71,8 +71,8 @@ trait Socket[F[_]] {
     */
   def writes: Pipe[F, Byte, Nothing]
 
-  /** Reads a file in chunks and writes it to a socket.
-    * Streams the file contents in chunks of the specified size and sends them over the socket.
+  /** Reads a file and writes it to a socket.
+    * Streams the file contents of the specified size and sends them over the socket.
     * The stream terminates when the entire file has reached end of file or the specified count is reached.
     *
     * @param file the file handle to read from
@@ -100,7 +100,7 @@ trait Socket[F[_]] {
   }
 
   /** Reads from a socket and writes to a file.
-    * Streams the socket data in chunks of the specified size and writes them to the file.
+    * Streams the socket data of the specified size and writes them to the file.
     * The stream terminates when the socket signals end of input or the specified count is reached.
     *
     * @param file the file handle to write to