Removed unused parameters
This commit is contained in:
parent
fd4eb256db
commit
27e8520eb5
@ -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)
|
||||
|
@ -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
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user