@@ -34,12 +34,18 @@ class DiscordChatInputImpl extends EventInputImpl[DiscordEvent, DiscordChatConne
3434 private val privateMessages = ListBuffer [DiscordChatMessage ]()
3535 private var channelId : Option [String ] = None
3636
37+ private val onMessageFn = onMessage _
38+ private val onMessageUpdateFn = onMessageUpdate _
39+ private val onMessageDeleteFn = onMessageDelete _
40+ private val onReactionAddedFn = onReactionAdded _
41+ private val onReactionRemovedFn = onReactionRemoved _
42+
3743 override def start (): Boolean = {
38- sourceConnector.get.addMessageReceivedListener(onMessage )
39- sourceConnector.get.addMessageUpdateListener(onMessageUpdate )
40- sourceConnector.get.addMessageDeleteListener(onMessageDelete )
41- sourceConnector.get.addReactionAddEventListener(onReactionAdded )
42- sourceConnector.get.addReactionDelEventListener(onReactionRemoved )
44+ sourceConnector.get.addMessageReceivedListener(onMessageFn )
45+ sourceConnector.get.addMessageUpdateListener(onMessageUpdateFn )
46+ sourceConnector.get.addMessageDeleteListener(onMessageDeleteFn )
47+ sourceConnector.get.addReactionAddEventListener(onReactionAddedFn )
48+ sourceConnector.get.addReactionDelEventListener(onReactionRemovedFn )
4349 true
4450 }
4551
@@ -82,11 +88,11 @@ class DiscordChatInputImpl extends EventInputImpl[DiscordEvent, DiscordChatConne
8288 * @return true if stopping was successful
8389 */
8490 override def stop (): Boolean = {
85- sourceConnector.get.removeMessageReceivedListener(onMessage )
86- sourceConnector.get.removeMessageUpdateListener(onMessageUpdate )
87- sourceConnector.get.removeMessageDeleteListener(onMessageDelete )
88- sourceConnector.get.removeReactionAddEventListener(onReactionAdded )
89- sourceConnector.get.removeReactionDelEventListener(onReactionRemoved )
91+ sourceConnector.get.removeMessageReceivedListener(onMessageFn )
92+ sourceConnector.get.removeMessageUpdateListener(onMessageUpdateFn )
93+ sourceConnector.get.removeMessageDeleteListener(onMessageDeleteFn )
94+ sourceConnector.get.removeReactionAddEventListener(onReactionAddedFn )
95+ sourceConnector.get.removeReactionDelEventListener(onReactionRemovedFn )
9096 true
9197 }
9298
0 commit comments