Commits on Aug 19, 2021

1. Add overlapping option to flatMap …

   This will cause the next stream to be added before any old streams are
   removed.
   
   ```
   const channelA = Kefir.stream((emitter) => {
     console.log('connect a');
     let count = 0, id = setInterval(() => emitter.value(count++), 250);
     return () => { console.log('disconnect a'); clearInterval(id); };
   });
   
   const channelB = Kefir.stream((emitter) => {
     console.log('connect b');
     let count = 0, id = setInterval(() => emitter.value(count++), 250);
     return () => { console.log('disconnect b'); clearInterval(id); };
   });
   
   const data = {
     a: channelA,
     b: Kefir.combine([channelA, channelB]),
     c: channelB,
   };
   
   Kefir.sequentially(1000, ['a', 'b', 'c', undefined])
     .flatMapLatest(p => p ? data[p] : Kefir.never())
     .log('result');
   ```
   
   With overlapping option disabled (default):
   
   ```
   > connect a
   > result <value> 0
   > result <value> 1
   > result <value> 2
   > disconnect a
   > connect a
   > connect b
   > result <value> [0, 0]
   > result <value> [1, 0]
   > result <value> [1, 1]
   > result <value> [2, 1]
   > result <value> [2, 2]
   > disconnect a
   > disconnect b
   > connect b
   > result <value> 0
   > result <value> 1
   > result <value> 2
   > disconnect b
   > result <end>
   ```
   
   With overlapping option enabled:
   
   ```
   > connect a
   > result <value> 0
   > result <value> 1
   > result <value> 2
   > connect b
   > result <value> [3, 0]
   > result <value> [3, 1]
   > result <value> [4, 1]
   > result <value> [4, 2]
   > disconnect a
   > result <value> 3
   > result <value> 4
   > result <value> 5
   > disconnect b
   > result <end>
   ```
   
   Closes: kefirjs#235 kefirjs#236

   

   bpinto committed Aug 19, 2021
   Configuration menu

   • View commit details
   • Copy full SHA for 923f4e9
   • Browse repository at this point

   Copy the full SHA

   923f4e9 View commit details

   Browse the repository at this point in the history