pipes-concurrent — adding broadcast clients

[Dima Gorbik]

Hello,

I am facing the following problem — I need to add broadcast clients dynamically. Monoidal concatenation only allows to specify these clients statically. Theoretically I could have a dispatching pipe that would operate on a number of boxes for all clients but then how would I add new boxes to the dispatcher dynamically without restarting the whole pipe. What's the best way to implement this?

Thanks,

Dima

[Daniel Díaz]

Hi, 

Perhaps you could put the list (or map) of boxes in an MVar (or TVar) and make the dispatching pipe check the MVar at each iteration.

[Gabriel Gonzalez]

One thing you can do is to `spawn` a new mailbox and then write any messages intended for a dynamic number of listeners to that mailbox.  Any time you want to create a new listener just fork a thread for that listener and have it listen to that mailbox's `Input`.

--
You received this message because you are subscribed to the Google Groups "Haskell Pipes" group.
To unsubscribe from this group and stop receiving emails from it, send an email to haskell-pipe...@googlegroups.com.
To post to this group, send email to haskel...@googlegroups.com.