RXJS: Получить дроссельные предметы -- rxjs пол Связанный проблема

RxJS: Get throttled items


1
vote

проблема

русский

Не могли бы вы дать мне знать, как получить дроссельные предметы с RXJS? В частности, давайте посмотрим на код ниже:

 <код> // test.js var Rx = require('rx'),     Subject = Rx.Subject,     source = new Subject(),     count = 0;  // generate items setInterval(     () => {         source.onNext(count++)     }, 100 )  var windowDuration = 200; source.throttle(windowDuration).subscribe(console.log);   

Код выше будет распечатан:

 <код> λ bigsonata test → node test.js 0 2 4 6 8 10 12 14 16 18 20 23   

Дроссельные элементы в этом случае нечетные номера.

Английский оригинал

Would you please let me know how to get throttled items with RxJS? Specifically let's have a look at the code below:

// test.js var Rx = require('rx'),     Subject = Rx.Subject,     source = new Subject(),     count = 0;  // generate items setInterval(     () => {         source.onNext(count++)     }, 100 )  var windowDuration = 200; source.throttle(windowDuration).subscribe(console.log); 

The code above will print out:

λ bigsonata test → node test.js 0 2 4 6 8 10 12 14 16 18 20 23 

The throttled items in this case is odd numbers.

</div
  
   
   

Список ответов

0
 
vote
 <код> zoo1  

Выход:

2

4

6

8

10

Смотрите этот jsbin

https://jsbin.com/xakato/3/edit?js , консоль, вывод

 
Rx.Observable.interval(1000).filter(i => i % 2 === 0).subscribe((x) => {     console.log(x); }); 

output:

2

4

6

8

10

see this JSBin

https://jsbin.com/xakato/3/edit?js,console,output

</div
 
 
 
 

Связанный проблема

1  Угловая форма Пользовательский валидатор HTTP наблюдаемый возвратный ноль на HTTP Call  ( Angular form custom validator http observable returning null on http call ) 
Я пытаюсь настроить поле формы, который проверит, существует ли электронная почта. Я посмотрел на несколько примеров и получила валидацию, но когда я реализую...

0  В каком порядке операторы RXJS могут быть использованы  ( In what order rxjs operators can be used ) 
Согласно этой документации https: //xgrommxx.github. io / rx-book / content / наблюдаемое / наблюдаемое_instance_methods / index.html Существует основное ра...

0  Оператор Timeout () не работает в трубе RXJS  ( Timeout operator not working in pipe rxjs subject ) 
У меня есть проблема с оператором тайм-аута в теме. Моя проблема выглядит как образец выше, но я получил весь источник, Ответ: наблюдаемый: 1. наблюдаемый...

0  Избирательные несколько ресурсов с использованием RxJS в угловых 5  ( Polling multiple resources using rxjs in angular 5 ) 
<Р> У меня есть требование опроса нескольких ресурсов с течением времени. Каждый раз, когда я начала опроса следует добавить его в какой-то опрос <сильный> бас...

1  Неожиданные Тоуэвеэнэнэнэнэнэнэн на Caveroror (RXJS)  ( Unexpected tohavebeencalled on catcherror rxjs ) 
Я использую угловые 6 Тур героев Приложение и пытаемся написать модульные тесты для <Код> Codes Price Size Time 2015-02-24...

315  Какой правильный способ поделиться результатом угловой HTTP Network Call в RXJS 5?  ( What is the correct way to share the result of an angular http network call in r ) 
Используя HTTP, мы называем метод, который выполняет сетевой вызов и возвращает HTTP наблюдаемый: <Код> getCustomer() { return this.http.get('/someUrl')...

1  RXJS REATTACH Слушатели после отключения WebSocket  ( Rxjs reattach listeners after websocket disconnect ) 
Я использую RXJS с угловым угловым, и у вас есть служба Websocket, которая представляет собой простую обертку над веб-сервером RXJS WebSocketsUbject. У меня...

4  Используйте TAP () вместо карты () RXJS и угловой  ( Use tap instead of map rxjs and angular ) 
У меня есть боевик вход в систему, который в основном проверяет, вошел ли пользователь IL в системе. Если он вошел в систему, он пропускает логин и перейти на...

0  получить первые значения в динамически построенной реактивной форме  ( Get first values of an dynamically built reactive form ) 
<Р> У меня есть компонент формы, где я построить динамичную форму со значениями вызова службы. Это работает правильно. <Р> Теперь я хочу, чтобы отобразить эти...

1  Подписаться внутри подписки, повторяя несколько раз  ( Subscribe inside a subscribe repeating multiple times ) 
У меня есть наблюдаемый, который выводит массив на подписку <код> appleProducts.subscribe((snap) => { console.log(snap); }); iphone.subscribe((snap) => ...

20  У нас есть ждать, пока все источники не дали одно значение  ( Have withlatestfrom wait until all sources have produced one value ) 
Я использую withLatestFrom оператора в RXJS в обычном порядке: <код> var combined = source1.withLatestFrom(source2, source3); ... Чтобы активно собрат...

1  Angular-httpClient: объект карты к свойствам массива  ( Angular httpclient map object to array properties ) 
Я звоню API, который возвращает мне объект JSON. Мне нужно сопоставить этот объект к массиву. Ниже приведен мой код, но после того, как API вызов не получаю...

2  RXJS - рассчитать время, проведенное внутри / снаружи div  ( Rxjs calculate time spent inside outside a div ) 
Я изучаю RXJS и хотел попробовать несколько примеров самостоятельно Но я не могу, кажется, не могу подумать, чтобы подумать реактивно. Я пытаюсь рассчитать ...

2  RXJS / наблюдаемый / из альтернативных для угловых 10, чтобы избежать предупреждения Commonjs или AMD зависимостей могут вызвать оптимизацию спасения  ( Rxjs observable of alternate for angular 10 to avoid warning commonjs or amd de ) 
После обновления на угловой 10, начал получать предупреждение ".. * .ts зависит от« RXJS / наблюдаемых / из ». Commonjs или amd зависимостей может вызвать ...

-1  Реактивная форма CombinelateSt объект, возможно, нулевой или неопределенный  ( Reactive form combinelatest object is possibly null or undefined ) 
Я хотел бы изменить значение формаррара в зависимости двух других элементов управления. На мой взгляд, я сделал все проверки, которые нужны, но TypectScript...

Связанный проблема

1  Угловая форма Пользовательский валидатор HTTP наблюдаемый возвратный ноль на HTTP Call 
0  В каком порядке операторы RXJS могут быть использованы 
0  Оператор Timeout () не работает в трубе RXJS 
0  Избирательные несколько ресурсов с использованием RxJS в угловых 5 
1  Неожиданные Тоуэвеэнэнэнэнэнэнэн на Caveroror (RXJS) 
315  Какой правильный способ поделиться результатом угловой HTTP Network Call в RXJS 5? 
1  RXJS REATTACH Слушатели после отключения WebSocket 
4  Используйте TAP () вместо карты () RXJS и угловой 
0  получить первые значения в динамически построенной реактивной форме 
1  Подписаться внутри подписки, повторяя несколько раз 
20  У нас есть ждать, пока все источники не дали одно значение 
1  Angular-httpClient: объект карты к свойствам массива 
2  RXJS - рассчитать время, проведенное внутри / снаружи div 
2  RXJS / наблюдаемый / из альтернативных для угловых 10, чтобы избежать предупреждения Commonjs или AMD зависимостей могут вызвать оптимизацию спасения 
-1  Реактивная форма CombinelateSt объект, возможно, нулевой или неопределенный