node-on

Node-js EventEmitter helpers

Install

npm install node-on

on

(...events: string[]) => (callback: (val: any) => void) => (...emitters: EventEmitter[]) => () => void

import{on}from'node-on'// we have the following emittersdeclareconste0: EventEmitter,e1: EventEmitterconstobserver=on('data','end'// events to listen)((value: any)=>{}// your callback)constunsub=observer(e0,e1// subscribe to emitters)// return unsubscribe function// unsubscribeunsub()

onEx

(...events: string[]) => (callback: (val: {value: any, event: string, index: number, emitterIndex: number, emitter: EventEmitter}) => void) => (...emitters: EventEmitter[]) => () => void

import{onEx}from'node-on'// we have the following emittersdeclareconste0: EventEmitter,e1: EventEmitterconstobserver=onEx('data','end'// events to listen)(({ value, event, index, emitterIndex, emitter })=>{}// your callback)constunsub=observer(e0,e1)// subscribe to emitters, return unsubscribe function// unsubscribeunsub()

onceAll

(...events: string[]) => (callback: (values: any[]) => void) => (...emitters: EventEmitter[]) => () => void

import{onceAll}from'node-on'// we have the following emittersdeclareconste0: EventEmitter,e1: EventEmitterconstobserver=onceAll('data','end'// events to listen)((values: any[])=>{}// your callback)constunsub=observer(e0,e1)// subscribe to emitters, return unsubscribe function// unsubscribeunsub()

onceAllEx

(...events: string[]) => (callback: (val: { value: any, event: string, index: number, emitter: EventEmitter, emitterIndex: number }) => void) => (...emitters: EventEmitter[]) => () => void

import{onceAll}from'node-on'// we have the following emittersdeclareconste0: EventEmitter,e1: EventEmitterconstobserver=onceAll('data','end'// events to listen)(({ value, event, index, emitter, emitterIndex })=>{}// your callback)constunsub=observer(e0,e1)// subscribe to emitters, return unsubscribe function// unsubscribeunsub()

onceAllPromise

(...events: string[]) => (...emitters: EventEmitter[]) => Promise<any[]>

import{onceAllPromise}from'node-on'// we have the following emittersdeclareconste0: EventEmitter,e1: EventEmitteronceAllPromise('data',// events to listen)(e0,e1).then(([valueFromEmitter0,valueFromEmitter1])=>{// your callback})

onceAllExPromise

(...events: string[]) => (...emitters: EventEmitter[]) => Promise<{ value: any, event: string, index: number, emitter: EventEmitter, emitterIndex: number }[]>

import{onceAllPromise}from'node-on'// we have the following emittersdeclareconste0: EventEmitter,e1: EventEmitteronceAllPromise('data'// events to listen)(e0,e1).then(([emitterExValue0,emitterExValue1])=>{// your callback})

onceAllPromiseReject

(rejectEvents: string[], resolveEvents: string[]) => (...emitters: EventEmitter[]) => Promise<any[]>

import{onceAllPromise}from'node-on'// we have the following emittersdeclareconste0: EventEmitter,e1: EventEmitteronceAllPromise(['error'],['data'])(e0,e1).then(([valueFromEmitter0,valueFromEmitter1])=>{// your callback}).catch((error: any)=>{// your error handler})

onceAllExPromiseReject

(rejectEvents: string[], resolveEvents: string[]) => (...emitters: EventEmitter[]) => Promise<{ value: any, event: string, index: number, emitter: EventEmitter, emitterIndex: number }[]>

import{onceAllPromise}from'node-on'// we have the following emittersdeclareconste0: EventEmitter,e1: EventEmitteronceAllPromise(['error'],['data'])(e0,e1).then(([valueExFromEmitter0,valueExFromEmitter1])=>{// your callback}).catch(({ value, event, index, emitterIndex, emitter })=>{// your error handler})

onceRace

(...events: string[]) => (callback: (val: any) => void) => (...emitters: EventEmitter[]) => () => void

import{onceRace}from'node-on'// we have the following emittersdeclareconste0: EventEmitter,e1: EventEmitterconstobserver=onceRace('data','end'// events to listen)((value: any)=>{}// your callback)constunsub=observer(e0,e1// subscribe to emitters)// return unsubscribe function// unsubscribeunsub()

onceRaceEx

(...events: string[]) => (callback: (val: { value: any, event: string, index: number, emitterIndex: number, emitter: EventEmitter }) => void) => (...emitters: EventEmitter[]) => () => void

import{onceRace}from'node-on'// we have the following emittersdeclareconste0: EventEmitter,e1: EventEmitterconstobserver=onceRace('data','end'// events to listen)(({value: any,emitterIndex: number,emitter: EventEmitter})=>{}// your callback)constunsub=observer(e0,e1// subscribe to emitters)// return unsubscribe function// unsubscribeunsub()

onceRacePromise

(...events: string[]) => (...emitters: EventEmitter[]) => Promise<any>

import{onceRacePromise}from'node-on'// we have the following emittersdeclareconste0: EventEmitter,e1: EventEmitteronceRacePromise('data','end'// events to listen)(e0,e1// subscribe to emitters).then((value: any)=>{// your callback})

onceRaceExPromise

(...events: string[]) => (...emitters: EventEmitter[]) => Promise<{ value: any, event: string, index: number, emitterIndex: number, emitter: EventEmitter }>

import{onceRaceExPromise}from'node-on'// we have the following emittersdeclareconste0: EventEmitter,e1: EventEmitteronceRacePromiseEx('data','end'// events to listen)(e0,e1// subscribe to emitters).then(({ value, event, index, emitterIndex, emitter })=>{// your callback})

onceRacePromiseReject

(...events: string[]) => (...emitters: EventEmitter[]) => Promise<any>

import{onceRacePromiseReject}from'node-on'// we have the following emittersdeclareconste0: EventEmitter,e1: EventEmitteronceRacePromise(['error'],['data'])(e0,e1// subscribe to emitters).then((value: any)=>{// your callback}).catch((error: any)=>{// error handler})

onceRaceExPromiseReject

(...events: string[]) => (...emitters: EventEmitter[]) => Promise<{ value: any, event: string, index: number, emitterIndex: number, emitter: EventEmitter }>

import{onceRaceExPromiseReject}from'node-on'// we have the following emittersdeclareconste0: EventEmitter,e1: EventEmitteronceRacePromiseEx(['error'],['data'])(e0,e1// subscribe to emitters).then(({ value, event, index, emitterIndex, emitter })=>{// your callback}).catch(({ value, event, index, emitterIndex, emitter })=>{// error handler})