Changed arrow functions to methods

Author: Bjornskjald

src/Client.ts

@@ -140,29 +140,29 @@ export default class Client extends (EventEmitter as { new(): ClientEmitter }) {
    * Indicate that the user is currently present in the conversation.
    * Only relevant for non-group conversations
    */
-  sendPresenceState = async (recipientUserId: string, present: boolean) => {
+  async sendPresenceState (recipientUserId: string, present: boolean) {
     const payload = new Payloads.PresenceState(recipientUserId, present)
-    this.mqttApi.sendPublish(payload.getTopic(), await Payloads.encodePayload(payload))
+    return this.mqttApi.sendPublish(payload.getTopic(), await Payloads.encodePayload(payload))
   }
 
   /**
    * Send "User is typing" message.
    * In a non-group conversation, sendPresenceState() must be called first.
    */
-  sendTypingState = async (threadOrRecipientUserId: string, present: boolean) => {
+  async sendTypingState (threadOrRecipientUserId: string, present: boolean) {
     const payload = new Payloads.TypingState(this.session.tokens.uid, present, threadOrRecipientUserId)
-    this.mqttApi.sendPublish(payload.getTopic(), await Payloads.encodePayload(payload))
+    return this.mqttApi.sendPublish(payload.getTopic(), await Payloads.encodePayload(payload))
   }
 
   /**
    * Mark a message as read.
    */
-  sendReadReceipt = async (message: Message) => {
+  async sendReadReceipt (message: Message) {
     const payload = new Payloads.ReadReceipt(message)
-    this.mqttApi.sendPublish(payload.getTopic(), await Payloads.encodePayload(payload))
+    return this.mqttApi.sendPublish(payload.getTopic(), await Payloads.encodePayload(payload))
   }
 
-  getThreadList = async (count: number): Promise<Thread[]> => {
+  async getThreadList (count: number): Promise<Thread[]> {
     const threads = await this.httpApi.threadListQuery(count)
     return threads.viewer.message_threads.nodes.map(parseThread)
   }

src/mqtt/MqttApi.ts

@@ -55,7 +55,7 @@ export default class MqttApi extends EventEmitter {
     this.connection.on('close', () => this.reconnect())
   }
 
-  reconnect = async () => {
+  async reconnect () {
     debugLog('reconnecting...')
     await this.connection.connect()
     await this.sendConnectMessage()
@@ -173,7 +173,7 @@ export default class MqttApi extends EventEmitter {
     return this.connection.writeMessage(message)
   }
 
-  parsePacket = async (packet: MqttPacket) => {
+  async parsePacket (packet: MqttPacket) {
     switch (packet.type) {
       case MessageType.ConnectAck:
         debugLog('Packet type: ConnectAck')