With this PR, the live stream of items are broadcast from the producer to all consumers via mediator that all consumers subscribe to. There are concerns that this solution will not scale well with a larger number of consumers. This strategy is also at odds with the framework hooks Helidon provides. The mediator must take greater efforts to make it work.
Given these drawbacks, we should refactor the application to use an intermediate data structure to store the inbound items from the producer. Consumers will then receive BlockItems from the intermediate data structure and pass them back to their downstream consumer.
With this PR, the live stream of items are broadcast from the producer to all consumers via mediator that all consumers subscribe to. There are concerns that this solution will not scale well with a larger number of consumers. This strategy is also at odds with the framework hooks Helidon provides. The mediator must take greater efforts to make it work.
Given these drawbacks, we should refactor the application to use an intermediate data structure to store the inbound items from the producer. Consumers will then receive BlockItems from the intermediate data structure and pass them back to their downstream consumer.