fn stop(&self) {
        self.management_command_sender
            .send(ManagementCommands::Stop)
            .expect("Failed to send ManagementCommands::Stop command");
        if let Some(handle) = self.receive_task_handle.lock().unwrap().take() {
            async_safe_block_on_await(handle).unwrap();
        }
    }
/// The method stops the `PeerFlowQueueMap`.
The method stops the `PeerFlowQueueMap`.
The method stops the ` PeerFlowQueueMap ` .
fn stop(&self) {
        self.management_command_sender
            .send(ManagementCommands::Stop)
            .expect("Failed to send ManagementCommands::Stop command");
        if let Some(handle) = self.receive_task_handle.lock().unwrap().take() {
            async_safe_block_on_await(handle).unwrap();
        }
    }
fn stop ( & self ) { self . management_command_sender . send ( ManagementCommands :: Stop ) . expect ( " " ) ; if let Some ( handle ) = self . receive_task_handle . lock ( ) . unwrap ( ) . take ( ) { async_safe_block_on_await ( handle ) . unwrap ( ) ; } }
The method stops the `PeerFlowQueueMap`.
The method stops the ` PeerFlowQueueMap ` .
&self
&self