Do not force rxjs

.gitignore

@@ -1,3 +1,4 @@
 node_modules
 dist
-session
+session
+sample

README.md

@@ -1,2 +1,3 @@
 # 🤖sulla
+
 Javascript whatsapp framework (web whatsapp driver)

package.json

@@ -1,6 +1,6 @@
 {
   "name": "sulla",
-  "version": "1.0.0",
+  "version": "1.0.1",
   "description": "Javascript whatsapp framework",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",

src/api/whatsapp.ts

@@ -1,5 +1,4 @@
 import { Page } from 'puppeteer';
-import { Subject } from 'rxjs';
 import { ExposedFn } from './functions/exposed.enum';
 import { Chat } from './model/chat';
 import { Contact } from './model/contact';
@@ -24,12 +23,10 @@ export class Whatsapp {
    * Listens to messages received
    * @returns Observable stream of messages
    */
-  public onMessage() {
-    const messageSubject = new Subject<Message>();
+  public onMessage(fn: (message: Message) => void) {
     this.page.exposeFunction(ExposedFn.OnMessage, (message: Message) =>
-      messageSubject.next(message)
+      fn(message)
     );
-    return messageSubject.asObservable();
   }
 
   /**

src/controllers/initializer.ts

@@ -7,7 +7,7 @@ const spinner = ora();
 /**
  * Should be called to initialize whatsapp client
  */
-export const init = async () => {
+export const create = async () => {
   spinner.start('Initializing whatsapp');
   let waPage = await initWhatsapp();
   spinner.succeed();

src/index.ts

@@ -1,3 +1,3 @@
 export { Chat, Contact, Message } from './api/model';
 export { Whatsapp } from './api/whatsapp';
-export { init } from './controllers/initializer';
+export { create } from './controllers/initializer';

src/lib/middleware.js

@@ -18,4 +18,3 @@ WAPI.waitNewMessages(false, function (data) {
         window[ExposedFn.OnMessage](message);
     });
 });
-