The whole registering a Channel(Reader/Writer)Manager seems a bit messy. Try to abstract its logic away into the Channel Manager.
|
channelManager.registerChannelWriteManager(id, channelWriteManager) |
|
channelManager.registerChannelReadManager(id, channelReadManager) |
The whole registering a Channel(Reader/Writer)Manager seems a bit messy. Try to abstract its logic away into the Channel Manager.
ScalingStream/src/main/java/org/example/scalingstream/dag/Operator.kt
Line 64 in 9de33ca
ScalingStream/src/main/java/org/example/scalingstream/dag/Operator.kt
Line 91 in 9de33ca