deepcrayon/lila
deepcrayon/lila
1
0
Fork 0
Code Releases Activity

distinct bus classifiers for 'socketLeave and 'socketEnter

Browse source
This commit is contained in:
Thibault Duplessis 2018-12-08 14:05:18 +07:00
parent bfa618f148
commit 9ef0a5d506
6 changed files with 9 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
modules/evalCache/src/main/Env.scala
View file

@ -38,7 +38,7 @@ final class Env(
upgrade = upgrade
)
system.lilaBus.subscribeFun('socketDoor) {
system.lilaBus.subscribeFun('socketLeave) {
case lila.socket.actorApi.SocketLeave(uid, _) => upgrade unregister uid
}

6
modules/socket/src/main/Channel.scala
View file

@ -8,7 +8,7 @@ import lila.hub.Trouper
final class Channel(system: ActorSystem) extends Trouper {
system.lilaBus.subscribe(this, 'socketDoor)
system.lilaBus.subscribe(this, 'socketLeave)
import Channel._
@ -16,12 +16,12 @@ final class Channel(system: ActorSystem) extends Trouper {
val process: Trouper.Receive = {
case SocketLeave(_, member) => members -= member
case Sub(member) => members += member
case UnSub(member) => members -= member
case SocketLeave(_, member) => members -= member
case Publish(msg) => members.foreach(_ push msg)
}
}

2
modules/socket/src/main/MoveBroadcast.scala
View file

@ -9,7 +9,7 @@ import lila.hub.actorApi.round.MoveEvent
private final class MoveBroadcast extends Actor {
override def preStart(): Unit = {
context.system.lilaBus.subscribe(self, 'moveEvent, 'socketDoor)
context.system.lilaBus.subscribe(self, 'moveEvent, 'socketLeave)
}
override def postStop(): Unit = {

2
modules/socket/src/main/Population.scala
View file

@ -10,7 +10,7 @@ private[socket] final class Population extends Actor {
val bus = context.system.lilaBus
override def preStart(): Unit = {
bus.subscribe(self, 'socketDoor)
bus.subscribe(self, 'socketEnter, 'socketLeave)
}
override def postStop(): Unit = {

4
modules/socket/src/main/SocketBase.scala
View file

@ -90,7 +90,7 @@ trait SocketBase[M <: SocketMember] extends Socket {
protected def quit(uid: Socket.Uid): Unit = withMember(uid) { member =>
members -= uid.value
lilaBus.publish(SocketLeave(uid, member), 'socketDoor)
lilaBus.publish(SocketLeave(uid, member), 'socketLeave)
}
protected def onDeploy(d: Deploy): Unit =
@ -115,7 +115,7 @@ trait SocketBase[M <: SocketMember] extends Socket {
eject(uid)
members += (uid.value -> member)
setAlive(uid)
lilaBus.publish(SocketEnter(uid, member), 'socketDoor)
lilaBus.publish(SocketEnter(uid, member), 'socketEnter)
}
protected def setAlive(uid: Socket.Uid): Unit = aliveUids put uid.value

2
modules/socket/src/main/UserRegister.scala
View file

@ -10,7 +10,7 @@ import lila.hub.actorApi.security.CloseAccount
private final class UserRegister extends Actor {
override def preStart(): Unit = {
context.system.lilaBus.subscribe(self, 'users, 'socketDoor, 'accountClose)
context.system.lilaBus.subscribe(self, 'users, 'socketEnter, 'socketLeave, 'accountClose)
}
override def postStop(): Unit = {