Fix take/skip last. - Githubissues

spring-attic / reactor-core-js

The Reactive-Streams based implementation of Reactor-Core in Javascript

Apache License 2.0

51 stars 9 forks source link

Fix take/skip last. #14

Open tsachev opened 6 years ago

tsachev commented 6 years ago

skip last subscriber did not call actual.onNext
fix ring buffer: producer index was not updated correctly
added tests for take/skip last n operators