fastrx

#rx4rx-fast the fast rxjs implemention

#install

npm i fastrx

#usage

import { rx } from 'fastrx';

rx.of(1,2,3).filter(x=>x<2).subscribe(console.log)

or

import {pipe,fromArray,filter,subscribe} from 'fastrx';
pipe(fromArray([1,2,3]), filter(x=>x<2), subscribe(console.log))

dataflow for 1000000 source events

lib	op/s	samples
rx4rx-lite	11.29 op/s ± 1.47%	(56 samples)
rx4rx-fast	22.56 op/s ± 1.77%	(57 samples)
cb-basics	9.56 op/s ± 1.73%	(49 samples)
xstream	5.37 op/s ± 0.68%	(30 samples)
most	17.32 op/s ± 1.93%	(82 samples)
rx 6	6.28 op/s ± 3.10%	(35 samples)

---

#extensible

Observable.create way

import { rx } from 'fastrx';
const myObservable = rx(sink=>{
    sink.next('data')
    sink.complete()
})
myObservable.subscribe(console.log)

or

import {pipe,subscribe} from 'fastrx';
const myObservable = ()=>sink=>{
    sink.next('data')
    sink.complete()
}
pipe(myObservable(), subscribe(console.log))

add to library

import { rx } from 'fastrx';
rx.myObservable = (args) => sink => {
    const id = setTimeout(()=>{
        sink.next(args)
        sink.complete()
    })
    sink.defer([clearTimeout,null,id])
    //or sink.defer(()=>clearTimeout(id))
}

then you can use your observable anywhere

import { rx} from 'fastrx';
rx.myObservable('something').subscribe(console.log)

or

import {pipe,myObservable} from 'fastrx';
pipe(myObservable('something'), subscribe(console.log))

vue2.0 usage

import { rx } from "fastrx";
import { vueHookEvent } from "fastrx/extention";
Vue.use(vueHookEvent);

Vue.prototype.$rx = rx;

//in vue
this.$rx.interval(1000).takeUntil(this.$fromEvent("destroyed")).subscribe(()=>{})

<template>
<div @click.native="handler"></div>
</template>
<script>
import {rx} from 'fastrx'
const ob = rx.eventHandler()
export default {
    data(){
        return {handler:ob.handler}
    },
    mounted(){
        ob.subscribe(()=>{
            
        })
    }
}
</script>

vue3.0 usage

<template>
<div @click.native="handler"></div>
</template>
<script>
import {rx} from 'fastrx'
import {onUnmounted} from 'vue'
export default {
    setup(){
        const ob = rx.eventHandler()
        ob.switchMapTo(rx.interval(1000)).takeUntil(rx.fromLifeHook(onUnmounted)).subscribe(()=>{
            
        })
        return {handler:ob.handler}
    }
}
</script>