Refine message bus command processing

cjdsellers · cjdsellers · commit 96ec0f9f6cb1 · 2024-10-20T17:02:26.000+11:00
diff --git a/nautilus_core/infrastructure/src/redis/cache.rs b/nautilus_core/infrastructure/src/redis/cache.rs
@@ -271,8 +271,6 @@ async fn process_commands(
             match rx.recv().await {
                 Some(msg) => {
                     if let DatabaseOperation::Close = msg.op_type {
-                        // Close receiver end of the channel
-                        drop(rx);
                         break;
                     }
                     buffer.push_back(msg)

Original file line number	Diff line number	Diff line change
`@@ -271,8 +271,6 @@ async fn process_commands(`
`271`	`271`	`match rx.recv().await {`
`272`	`272`	`Some(msg) => {`
`273`	`273`	`if let DatabaseOperation::Close = msg.op_type {`
`274`		`- // Close receiver end of the channel`
`275`		`- drop(rx);`
`276`	`274`	`break;`
`277`	`275`	`}`
`278`	`276`	`buffer.push_back(msg)`