1.3.3 • Published 10 months ago
ion-streamer v1.3.3
ION-STREAMER
to produce and consume redis streams in non-blocking manner. ION-Streamer listens to streams in subprocess.
example usage
const StreamManager = require('ion-streamer');
const sm = new StreamManager({prefix: "SL", url: "redis://127.0.0.1:6379"});
/** create consumer **/
const StreamManager = require('./index.js');
const sm = new StreamManager({prefix: "SL", url: "redis://127.0.0.1:6379"});
const consumer = sm.consumer({
key: 'konafa',
block: 0,
keepAlive: true,
onMessage: (d)=>{console.log(`got message`, d)},
onError: (d)=>{console.log(`got error`, d)},
onClose: ()=>{console.log(`got close`)},
})
const producer = sm.producer();
setInterval(()=>{
producer.emit({key:'konafa', data: {mxg:'1'}});
}, 100);
setTimeout(()=>{consumer.close()}, 7000)
2.0.0
10 months ago
1.3.3
1 year ago
1.3.2
1 year ago
1.3.1
2 years ago
1.3.0
2 years ago
1.2.9
2 years ago
1.2.8
2 years ago
1.2.7
2 years ago
1.2.6
2 years ago
1.2.5
2 years ago
1.2.4
2 years ago
1.2.3
2 years ago
1.2.2
2 years ago
1.2.1
2 years ago
1.2.0
2 years ago
1.1.7
2 years ago
1.1.6
3 years ago
1.1.5
3 years ago
1.1.4
3 years ago
1.1.2
3 years ago
1.1.1
3 years ago
1.1.0
3 years ago
1.0.9
3 years ago
1.0.8
3 years ago
1.0.7
3 years ago
1.0.6
3 years ago
1.0.5
3 years ago
1.0.4
3 years ago
1.0.3
3 years ago
1.0.2
3 years ago
1.0.1
3 years ago
1.0.0
3 years ago