Kinda leak inside of map

[wclr]

import xs from 'xstream'

let A = xs.periodic(100)
let B = xs.periodic(200)

// A.withLatestFrom(B, (a, b) => a + b)
let C = B.map(b => A.map(a => a + b).debug('A')).flatten().take(1)

C.addListener({
  next: (c) => console.log('C', c),
  error: () => {},
  complete: () => {}
})

Output:

A: 0
C: 0
A: 1
A: 2
A: 3
...

http://www.webpackbin.com/EkUus9V8W

if .take(2) it doesn't leak.

[staltz]

This was a bug in flatten() actually. Just fixed it. Will release v5.1.1 soon.

[staltz]

Fixed in https://github.com/staltz/xstream/blob/master/CHANGELOG.md#511-2016-07-05