GenStage.PartitionDispatcher with dynamic partitions


I would like to know if it would be possible to use GenStage.PartitionDispatcher but with dynamic partition management based on a callback.

Here’s what I need: I have a source event (producer) with several producer_consumers who can subscribe/unsubscribe dynamically. Each producer_consumers has a unique id. Events arriving at my producer also have a tag corresponding to the id of the producer_consumers to which they must be redirected.

The problem is the dynamic nature of producer_consumers and the fact that I don’t know the IDs in advance.

Is there already a solution, or would I have to write my own GenStage.Dispatcher?