compose2: fix type signature errors (5c77ff9)
core: fix map type signature (133c400)
dropRepeats: move dropRepeats from core to extra (78851c8)
filterMap: properly catch errors that could be thrown (8ff48a5)
flattenConcurrently: fix inner management when optimization is off (da1f379)
fromArray: rename from() producer to fromArray() (05f519a)
fromEvent: rename static domEvent() to fromEvent() as extra (c481cc8)
MemoryStream: fix how MemoryStream handles late sync emissions (00de09d)
operator: add more tear down logic in _stop() in operators (2483107)
operator: fix all operators redirection of error/complete (2caa2ca)
package.json: no postinstall npm script anymore (4011aa1)
periodic: rename interval() factory to periodic() (6a2adc5)
src: make index be an import facade for core.ts (180f7c4)
Stream: fix unsubscription semantics w.r.t. restarting (9a0f3af)
Stream: stop the producer syncly after stream completes (faba7bf)
Stream: stop the producer syncly after the Stream errors (6c803ac)
Stream: use underscore for pseudo-private fields in Stream (95f2ebb)
take: fix take() operator, and also combine and merge (c5fdfc0)

Features

concat: implement extra concat() operator (7652011)
core: flatten and flattenConcurrently should optimize for FilterMapOperator (e1bebff)
core: implement filter + map fusion (b0507e6)
core: use filterMap fusion for map() + filter (a723fa4)
createWithMemory: rename xs.MemoryStream to xs.createWithMemory (c88d6c2)
debounce: implement debounce operator (7dfb709)
debounce: make debounce an extra operator (34fd6c1)
delay: implement extra operator delay() and compose() (48c5abc)
domEvent: implement domEvent stream constructor (ad40a08)
drop: rename skip() to drop() (cab26a9)
dropRepeats: implement core instance operator dropRepeats() (b7dccf9)
emptyObserver: makes emptyObserver noop functions instead of null (e1d2537)
endWhen: implement operator endWhen(), add tests (23099ef)
factory: add factory from() with FromMachine (e76acef)
factory: implement merge() with MergeProducer (42b6f12)
filterMap: implement all combinations of filter and map fusion (5eb5822)
flatten: implement flatten operator, a.k.a. switch() (6255e53)
flattenConcurrently: rename flatten to flattenConcurrently (b3a87ee)
fromPromise: implement factory fromPromise() (ad0ccfd)
imitate: implement imitate() operator for circular dependencies (6545670)
index: export new domEvent constructor (870fdc6)
mapTo: implement mapTo (f73bc8e)
MapTo: adjust to more private variables (a5ed5ab)
Observer: rename complete() callback to end() (d282684)
operator: implement combine(), both static and instance (f65a6a3)
operator: implement debug() operator with DebugMachine (e2a0342)
operator: implement filter operator with FilterMachine (a74f160)
operator: implement flatten() operator (4800873)
operator: implement fold operator with FoldMachine (57453f2)
operator: implement last() operator with LastMachine (747e255)
operator: implement map operator with MapMachine (76df500)
operator: implement skip operator with SkipMachine (32dd8ac)
operator: implement take operator with TakeMachine (6e1d0db)
pairwise: implement extra operator pairwise() (5b1ec51)
remember: implement RememeberProducer (7279ad8)
RememberOperator: adjust to work with MemoryStream (0898404)
replaceError: implement replaceError(), wrap code with try-catch (ffa5976)
shamefullySendNext: introduce shamefullySendNext and hide _next callback (552caff)
startWith: implement startWith operator (3489ce3)
Stream: add a concept of current value (cc5650f)
Stream: add debounce to Stream prototype (f44b819)
Stream: add mapTo to Stream prototype (58c83f9)
Stream: add never() and empty() stream factories (04f59b0)
Stream: implement really simply Stream and interval() factory (a3a08e7)
Stream: implement Stream (86d68ff)
Stream: implement xs.of() (f86fd49)
takeUntil: implement and test takeUntil() (304bed1)
throw: implement new static factory throw() (76879a5)

Performance Improvements

core: have FilterMapOperator extend MapOperator (e0c153a)
debug: improve performance of debug() operator, using Proxy class (9f766af)
filter-map-reduce: add preliminary perf micro benchmarks (8b1f2d3)
filter-map-reduce: improve filter-map-reduce test to actually do reduce() too (7ff9fd0)
fold: improve performance by using shorter names (8a25fe7)
from: improve from factory perf by renaming a var (a814c8a)
fromArray: rename/fix from() to fromArray() in perf benchmarks (a433dd5)
merge: add merge performance benchmark (de9f002)
operator: fix all operators to refer this.proxy initially to emptyObserver (ad210fc)
operator: replace operator proxies with class, improves perf (2e6ec27)
perf: fix xstream perf benchmark for merge() (4758a1d)
scan: add performance benchmark for fold (5d5ef94)
skip: improve skip perf by using Proxy Observer class (5233f43)
Stream: improve performance of Observer methods in Stream (465f22d)
Stream: remove this.num in Stream to improve perf (53bcaad)
Stream: squeeze kB size in map and filter fusion (23ac9d0)
Stream: tiny saving of lookups and source code size (6527129)
take: improve take() perf by using Proxy Observer class (6eae1a9)

Reverts

takeUntil: revert takeUntil implementation (6f62fc1)

1.0.0

Diff

cycle

published 1.0.0 • 9 years ago

Changelog

Source

11.1.0 (2017-12-12)

Bug Fixes

package: add yarn.lock file to avoid ambiguities (d745aa6)
package: lock symbol-observable to 1.0.4 (9de613a), closes #234 benlesh/symbol-observable#34

0.0.1

Diff

staltz

published 0.0.1 • 9 years ago

…

8 9