Как работает rxjs с точки зрения потоков - PullRequest
Новая
       12

Как работает rxjs с точки зрения потоков

0 голосов
/ 01 июня 2018

В настоящее время я использую приложение angular2, в котором я использую rxjs.Мне нужно использовать Observables с обещаниями и интервалом.Сейчас я пытаюсь понять, какие последствия они представляют с точки зрения потоков.

Рассмотрим следующий бит кода для службы, которая будет внедрена в компонент: 

import { interval } from "rxjs";

@Injectable()
export class ExampleService {
    observable: any;

    constructor() {
        this.observable = interval(1000);

        this.observable.subscribe( (x) =>
            //Do something every 1000 seconds
        );
    }
}

Я пытаюсьпонять, как опрос каждые 1000 миллисекунд будет работать с точки зрения генерации потоков.Создан ли отдельный поток, который отслеживает опрос через подписчиков?

Было бы замечательно, если бы я мог получить общее представление о том, как связать потоки со сценариями, включающими Observables, и как избежать блокировки.

1 Ответ

0 голосов
/ 01 июня 2018

попробуй 

this.observable.valueChanges
  .debounceTime(1000)
  .subscribe(value =>  {
  });
...