import { Wod, useThread } from "@redtea/wod"

const wod = require("@redtea/wod");

// Create a instance of Wod. It also spawn a new web worker instance
const Worker_1 = new Wod(); // or Wod.spawn()
// Define event listeners
const listener = (event) => console.log(event.data);
const errorListener = (event) => console.log(event.message);
// Subscribe to any message from the Worker_1 thread
// The same as WebWorker.onmessage = function() {} 
Worker_1.on('message', listener);
// Subscribe to any errors that may occure in the Worker_1 thread
// The same as WebWorker.onerror = function() {} 
Worker_1.on('error', errorListener);
// This line execute the function in the Worker_1 thread context and post the 
// message to the Main thread. As result, message 'Message from Worker_1'
// will output to console of the Main thread
Worker_1.exec(() => postMessage('Message from Worker_1'));
// Using decorator
// Create a decorator that execute the function in the Worker_1 thread
let sayHelloToTheMainThread = useThread(Worker_1)(() => postMessage('Hello from Worker1'));
// This will print 'Hello from Worker1' to console of the Main thread
sayHelloToTheMainThread();
// Catching errors
// As we was subscribe to any error event from the Worker_1 above
// this will print the error message to the Main thread's console
Worker_1.exec(() => throw 'Error from Worker_1');
// Off event listener
Worker_1.off('message', listener);
Worker_1.off('error', errorListener);
// Terminate the worker
Worker_1.terminate();

// print 6
Worker.exec((a, b, c) => console.log(a + b + c), [1, 2, 3]);

const wrapped = useThread(WodInstance)(function(arg) { postMessage(arg); });
wrapped('hello');