redis-stream-example.js

// 
// example
var Redis = require('redis-stream')
  , redis = new Redis(6379, 'localhost')

// 
// reimplementation of rpoplpush with streams
var rpoplpush = redis.stream('rpop')
rpoplpush.pipe(redis.stream('lpush', 'list-two'))
rpoplpush.write('list-one')
rpoplpush.end()

// 
// get all members in `myset` and lpush them to `myset-two`
var smemberslpush = redis.stream('smembers')
smemberslpush.pipe(redis.stream('lpush', 'myset-two'))
smemberslpush.write('myset')
smemberslpush.end()