The current subscribers of the observer repeatedly process a message multiple times.
What is the new behavior?
By using shareReplay(1), the message processing results are cached and shared, avoiding duplicate processing while ensuring all subscribers can correctly handle different messages. These changes ensure that each message is processed only once without affecting the original business logic and functionality.
Please describe the new behavior or provide screenshots.
What is the current behavior?
The current subscribers of the observer repeatedly process a message multiple times.
What is the new behavior?
By using shareReplay(1), the message processing results are cached and shared, avoiding duplicate processing while ensuring all subscribers can correctly handle different messages. These changes ensure that each message is processed only once without affecting the original business logic and functionality. Please describe the new behavior or provide screenshots.
Does this PR introduce a breaking change?