Skip to content

Commit 1a471d8

Browse files
committed
minor handler batch refactor
1 parent 61380ef commit 1a471d8

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

src/main/scala/LilaHandler.scala

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -119,8 +119,7 @@ final class LilaHandler(
119119
append = (prev, elem) => prev.fold(NonEmptyList.one(elem))(_.prepend(elem)),
120120
emit = (roomId, batch) =>
121121
Monitor.handler.batch.record(batch.size)
122-
if batch.tail.isEmpty then tellRoomVersion(roomId, batch.head)
123-
else tellRoomVersionBatch(roomId, batch)
122+
tellRoomVersionBatch(roomId, batch)
124123
)
125124

126125
_ match
@@ -191,8 +190,10 @@ final class LilaHandler(
191190
publish(_.room(roomId), versioned)
192191

193192
private def tellRoomVersionBatch(roomId: RoomId, batch: NonEmptyList[ClientIn.Versioned]): Unit =
194-
History.room.add(roomId, batch)
195-
publish(_.room(roomId), ClientIn.VersionedBatch(batch))
193+
if batch.tail.isEmpty then tellRoomVersion(roomId, batch.head)
194+
else
195+
History.room.add(roomId, batch)
196+
publish(_.room(roomId), ClientIn.VersionedBatch(batch))
196197

197198
private val roomHandler: Emit[LilaOut] =
198199
case TellRoomVersion(roomId, version, troll, payload) => tellRoomVersion(roomId, version, troll, payload)

0 commit comments

Comments
 (0)