If you havent seen redis-stream, it might help a bit.
https://github.com/tblobaum/redis-stream
var Redis = require('redis-stream')
, client = new Redis('localhost', 6379, 0)
, subscribe = client.stream('subscribe')
subscribe.pipe(process.stdout)
subscribe.write('channel-one')
Thomas Blobaum
https://github.com/tblobaum
On Fri, Dec 21, 2012 at 2:20 PM, Arunoda Susiripala
<[email protected]> wrote:
> Yes I know buffering is not a good solution.
> Seems like need to implement this with the old stream api. (emitting data
> events).
>
>
> On Sat, Dec 22, 2012 at 12:41 AM, Bradley Meck <[email protected]>
> wrote:
>>
>> Personally I did not want to write a buffering system for in memory _read
>> and just used a PassThrough stream for node-tart's substream parts :
>> https://github.com/bmeck/node-tart/blob/master/lib/substream.js . I'm trying
>> as well to find a sane way to allow internal buffering from a different
>> stream but have not thought of an elegant solution.
>>
>>
>> On Friday, December 21, 2012 10:07:07 AM UTC-6, Arunoda Susiripala wrote:
>>>
>>> Hi,
>>>
>>> I was looking at the new readable stream documentation and it said that
>>> we've to implement _read() method in order to implement the readable stream.
>>>
>>> But I have a problem?
>>>
>>> I want to create a readable stream where it's source is redis
>>> subscribe(). How can I implement a readable stream for this with the new
>>> API?
>>>
>>> Do I need to buffer incoming data from redis?
>>>
>>>
>>> --
>>> Arunoda Susiripala
>>>
>>> @arunoda
>>> https://github.com/arunoda
>>> http://www.linkedin.com/in/arunoda
>>
>> --
>> Job Board: http://jobs.nodejs.org/
>> Posting guidelines:
>> https://github.com/joyent/node/wiki/Mailing-List-Posting-Guidelines
>> You received this message because you are subscribed to the Google
>> Groups "nodejs" group.
>> To post to this group, send email to [email protected]
>> To unsubscribe from this group, send email to
>> [email protected]
>> For more options, visit this group at
>> http://groups.google.com/group/nodejs?hl=en?hl=en
>
>
>
>
> --
> Arunoda Susiripala
>
> @arunoda
> https://github.com/arunoda
> http://www.linkedin.com/in/arunoda
>
> --
> Job Board: http://jobs.nodejs.org/
> Posting guidelines:
> https://github.com/joyent/node/wiki/Mailing-List-Posting-Guidelines
> You received this message because you are subscribed to the Google
> Groups "nodejs" group.
> To post to this group, send email to [email protected]
> To unsubscribe from this group, send email to
> [email protected]
> For more options, visit this group at
> http://groups.google.com/group/nodejs?hl=en?hl=en
--
Job Board: http://jobs.nodejs.org/
Posting guidelines:
https://github.com/joyent/node/wiki/Mailing-List-Posting-Guidelines
You received this message because you are subscribed to the Google
Groups "nodejs" group.
To post to this group, send email to [email protected]
To unsubscribe from this group, send email to
[email protected]
For more options, visit this group at
http://groups.google.com/group/nodejs?hl=en?hl=en
