diff --git a/src/WAConnection/7.MessagesExtra.ts b/src/WAConnection/7.MessagesExtra.ts
index bd9381e..68361be 100644
--- a/src/WAConnection/7.MessagesExtra.ts
+++ b/src/WAConnection/7.MessagesExtra.ts
@@ -144,7 +144,7 @@ export class WAConnection extends Base {
      * @param chunkSize the number of messages to load in a single request
      * @param mostRecentFirst retreive the most recent message first or retreive from the converation start
      */
-    loadAllMessages(jid: string, onMessage: (m: WAMessage) => void, chunkSize = 25, mostRecentFirst = true) {
+    loadAllMessages(jid: string, onMessage: (m: WAMessage) => Promise<void>|void, chunkSize = 25, mostRecentFirst = true) {
         let offsetID = null
         const loadMessage = async () => {
             const {messages} = await this.loadMessages(jid, chunkSize, offsetID, mostRecentFirst)
@@ -152,12 +152,12 @@ export class WAConnection extends Base {
             let lastMessage
             if (mostRecentFirst) {
                 for (let i = messages.length - 1; i >= 0; i--) {
-                    onMessage(messages[i])
+                    await onMessage(messages[i])
                     lastMessage = messages[i]
                 }
             } else {
                 for (let i = 0; i < messages.length; i++) {
-                    onMessage(messages[i])
+                    await onMessage(messages[i])
                     lastMessage = messages[i]
                 }
             }