Closed minwoox closed 3 months ago
Static analysis was not easy because two executors were used together in StreamMessageProcessor. How about refactoring the implementation later to delegate the logic to DownstreamSubscription if DownstreamSubscription.executor is needed?
That's a good suggestion. ๐ Addressed it from this PR. :wink:
Thanks for the quick review. ๐ I'll test it with the snapshot version to ensure the problem is fixed.
Motivation: Subscriber methods must be called by the executor that is specified when subscribing to a
StreamMessage
. However, the methods of the duplicator's child stream subscriber are currently being called from the duplicator's executor, which is incorrect.Modifications:
Result: