rxjs-worker

KO | EN

gitlite — search

#javascript #python #hacktoberfest #react #ai #typescript #go #machine-learning #docker #macos #java #awesome #kubernetes #security

(★ 17)

Standard rxjs operators built to run in web workers

rxjs-worker Latest Version Download

Download Latest Version (.zip)

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

# rxjs-worker [![CircleCI](https://circleci.com/gh/deebloo/rxjs-worker.svg?style=svg)](https://circleci.com/gh/deebloo/rxjs-worker)

RXJS extensions for adding web worker functionality via operators and observables

## Observables

### observable.fromWorker()
Create an observable from a webworker, path, or function
```TS
// web worker
const myWorker = new Worker('path/to/web-worker.js');
const observable1 = Observable.fromWorker(myWorker);

// function
const observable2 = Observable.fromWorker(() => {
  self.postMessage('Hello World');
});

// string
const observable3 = Observable.fromWorker('path/to/web-worker.js');
```

## Operators

### observable.mapWorker()
simple map function that runs in a web worker
```TS
Observable
  .from(['Hello World'])
  .mapWorker(strng => {
    return strng + ', I am from a worker.';
  })
  .subscribe(res => {
    console.log(res); // Hello World, I am from a worker
  });
```

### observable.filterWorker()
returns either the result or null
```TS
Observable
  .from(['Hello World'])
  .filterWorker(strng => {
    return strng === 'Hello World';
  })
  .subscribe(res => {
    console.log(res); // Hello World
  });
```

rxjs-worker

rxjs-worker Latest Version Download

Today's picks

Was this content helpful?

Recent Feedback

rxjs-worker

rxjs-worker Latest Version Download

Today's picks

Was this content helpful?

Recent Feedback

Download README