Added forEachConnection() method to run a function callback against each connection
This commit is contained in:
parent
4008dd6470
commit
e035d86ee0
|
@ -26,9 +26,9 @@ import dorkbox.network.connection.Connection
|
||||||
import dorkbox.network.connection.EndPoint
|
import dorkbox.network.connection.EndPoint
|
||||||
import dorkbox.network.connection.ListenerManager
|
import dorkbox.network.connection.ListenerManager
|
||||||
import dorkbox.network.connectionType.ConnectionRule
|
import dorkbox.network.connectionType.ConnectionRule
|
||||||
|
import dorkbox.network.coroutines.SuspendWaiter
|
||||||
import dorkbox.network.exceptions.ServerException
|
import dorkbox.network.exceptions.ServerException
|
||||||
import dorkbox.network.handshake.ServerHandshake
|
import dorkbox.network.handshake.ServerHandshake
|
||||||
import dorkbox.network.coroutines.SuspendWaiter
|
|
||||||
import dorkbox.network.rmi.RemoteObject
|
import dorkbox.network.rmi.RemoteObject
|
||||||
import dorkbox.network.rmi.RemoteObjectStorage
|
import dorkbox.network.rmi.RemoteObjectStorage
|
||||||
import dorkbox.network.rmi.TimeoutException
|
import dorkbox.network.rmi.TimeoutException
|
||||||
|
@ -584,6 +584,15 @@ open class Server<CONNECTION : Connection>(config: ServerConfiguration = ServerC
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Execute the unit function against all existing connections
|
||||||
|
*/
|
||||||
|
fun forEachConnection(function: (connection: CONNECTION) -> Unit) {
|
||||||
|
connections.forEach {
|
||||||
|
function(it)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Closes the server and all it's connections. After a close, you may call 'bind' again.
|
* Closes the server and all it's connections. After a close, you may call 'bind' again.
|
||||||
*/
|
*/
|
||||||
|
|
Loading…
Reference in New Issue
Block a user