aww

KO | EN

gitlite — search

#python #hacktoberfest #ai #typescript #go #golang #linux #docker #macos #java #kubernetes #awesome-list #security #open-source

(★ 111)

Async Iterables Interfaces for Web Workers

파일 탐색기

최종 버전 다운로드 (.zip)

- AISource.js
- AIWorker.js
- AsyncQueue.js
- index.js
.editorconfig
.gitignore
LICENSE
package-lock.json
package.json
README.md
rollup.config.js

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

# aww

__Async Iterables Interfaces for Web Workers__

This is a proof of concept library that enables async iteration with web workers. Errors handling is not yet supported.

```sh
npm i -S aww
```

Do not use the `postMessage` method of my wrappers while you are async iterating: use the `reply` method instead.
&nbsp;

## How to iterate over the invoker's incoming data (from the worker perspective)

### worker.js
```js
import { AISource } from 'aww';

const delay = (ms, v) => new Promise(res => setTimeout(res, ms, v));

;(async () => {

// will handle onmessage events and other stuff
    // it's an async iterable
    const source = new AISource();

for await(const msg of source) {
      console.log(`${msg.data} received inside worker`);
      await delay(2000, msg); // fake long task

// next messages from the main will be handled by the async iteration
      // no sense making this awaitable
      // DO NOT USE postMessage!
      source.reply("It's all good from worker!");
    }

})();
```

### main.js
```js
import { AIWorker } from 'aww';

const delay = (ms, v) => new Promise(res => setTimeout(res, ms, v));

;(async () => {

const myWorker = new AIWorker(new Worker('./worker.js'));

let i = 0;
    while(true) {
        await delay(1000);

// you can await the response from the worker, but it is not mandatory
        await myWorker.postMessage(i++).then(({data}) => console.log(data));

/*
          alternative syntax
          const { data } = await myWorker.postMessage(i++);
          console.log(data);
        */
       }

})();
```

<img src="https://s3.gifyu.com/images/ezgif-5-479e2f28a99e.gif" width="700"/>
&nbsp;

## How to iterate over the worker's incoming data (from the invoker perspective)

### main.js
```js
import { AIWorker } from 'aww';

const delay = (ms, v) => new Promise(res => setTimeout(res, ms, v));

;(async () => {

const myWorker = new AIWorker(new Worker('./worker.js'));

// will handle onmessage events and other stuff
    // it's an async iterable
    for await(const msg of myWorker) {
      console.log(`${msg.data} received inside main`);
      await delay(2000, msg); // fake long task

// next messages from the main will be handled by the async iteration
      // no sense making this awaitable
      // DO NOT USE postMessage!
      myWorker.reply("It's all good from main!");
    }

})();
```

### worker.js
```js
import { AISource } from 'aww';

const delay = (ms, v) => new Promise(res => setTimeout(res, ms, v));

;(async () => {

const source = new AISource();

let i = 0;
    while(true) {
        await delay(1000);

// you can await the response from the main, but it is not mandatory
        await source.postMessage(i++).then(({data}) => console.log(data));

/*
          alternative syntax
          const { data } = await source.postMessage(i++);
          console.log(data);
        */
    }

})();
```

<img src="https://s3.gifyu.com/images/ezgif-5-1427410b906b.gif" width="700"/>
&nbsp;

## How to iterate over both at the same time

### main.js
```js
import { AIWorker } from 'aww';

const delay = (ms, v) => new Promise(res => setTimeout(res, ms, v));

;(async () => {

const myWorker = new AIWorker(new Worker('./worker.js'));

// start the iteration posting a message
    // because both the main and the worker are waiting to start the iteration
    // not awaitable because the subsequent async iteration will handle worker's messages
    // DO NOT USE postMessage!
    myWorker.reply("Please start!");

for await(const msg of myWorker) {
      console.log(`${msg.data} received inside main`);
      await delay(1000, msg); // fake long task

// next messages from the main will be handled by the async iteration
      // no sense making this awaitable
      // DO NOT USE postMessage!
      myWorker.reply("It's all good from main!");
    }

})();
```

### worker.js
```js
import { AISource } from 'aww';

const delay = (ms, v) => new Promise(res => setTimeout(res, ms, v));

;(async () => {

const source = new AISource();

for await(const msg of source) {
      console.log(`${msg.data} received inside worker`);
      await delay(2000, msg); // fake long task

// next messages from the main will be handled by the async iteration
      // no sense making this awaitable
      // DO NOT USE postMessage!
      source.reply("It's all good from worker!");
    }

})();
```

aww

파일 탐색기

오늘의 추천 프로젝트

Was this content helpful?

Recent Feedback

aww

파일 탐색기

오늘의 추천 프로젝트

Was this content helpful?

Recent Feedback

Download README