Method disconnect

crates/buttplug_server/src/server.rs:207–232

Disconnects the server from a client, if it is connected.

(&self)

  /// Disconnects the server from a client, if it is connected.
  pub fn disconnect(&self) -> BoxFuture<'_, Result<(), message::ErrorV0>> {
    debug!("Buttplug Server {} disconnect requested", self.server_name);
    let ping_timer = self.ping_timer.clone();
    // As long as StopScanning/StopAllDevices aren't changed across message specs, we can inject
    // them using parse_checked_message and bypass version checking.
    let stop_scanning_fut = self.parse_checked_message(
      ButtplugCheckedClientMessageV4::StopScanning(StopScanningV0::default()),
    );
    let stop_fut =
      self.parse_checked_message(ButtplugCheckedClientMessageV4::StopCmd(StopCmdV4::default()));
    let state = self.state.clone();
    async move {
      {
        let mut state_guard = state.write().expect("State lock poisoned");
        *state_guard = ConnectionState::Disconnected;
      }
      ping_timer.stop_ping_timer().await;
      // Ignore returns here, we just want to stop.
      info!("Server disconnected, stopping device scanning if it was started...");
      let _ = stop_scanning_fut.await;
      info!("Server disconnected, stopping all devices...");
      let _ = stop_fut.await;
      Ok(())
    }
    .boxed()
  }

  pub fn shutdown(&self) -> ButtplugServerResultFuture {
    let device_manager = self.device_manager.clone();