diff --git a/src/dorkbox/network/connection/EndPoint.kt b/src/dorkbox/network/connection/EndPoint.kt
index 60aee898..9c29f568 100644
--- a/src/dorkbox/network/connection/EndPoint.kt
+++ b/src/dorkbox/network/connection/EndPoint.kt
@@ -510,7 +510,7 @@ internal constructor(val type: Class<*>,
                     // NOTE: This MUST be on a new co-routine
                     actionDispatch.launch {
                         try {
-                            streamingManager.processDataMessage(message, this@EndPoint, connection)
+                            streamingManager.processDataMessage(message, this@EndPoint)
                         } catch (e: Exception) {
                             logger.error("Error processing StreamingMessage", e)
                             listenerManager.notifyError(connection, e)
diff --git a/src/dorkbox/network/connection/streaming/StreamingManager.kt b/src/dorkbox/network/connection/streaming/StreamingManager.kt
index 101fe757..a2b7074f 100644
--- a/src/dorkbox/network/connection/streaming/StreamingManager.kt
+++ b/src/dorkbox/network/connection/streaming/StreamingManager.kt
@@ -178,7 +178,7 @@ internal class StreamingManager<CONNECTION : Connection>(private val logger: KLo
     *
     * NOTE sending a huge file can prevent other other network traffic from arriving until it's done!
     */
-    fun processDataMessage(message: StreamingData, endPoint: EndPoint<CONNECTION>, connection: CONNECTION) {
+    fun processDataMessage(message: StreamingData, endPoint: EndPoint<CONNECTION>) {
         // the receiving data will ALWAYS come sequentially, but there might be OTHER streaming data received meanwhile.
         val streamId = message.streamId