Method connect

src/droidplug/peripheral.rs:259–289

(&self)

    }

    async fn connect(&self) -> Result<()> {
        let future = self.with_obj(|env, obj| JSendFuture::try_from(obj.connect()?))?;
        let result_ref = future.await?;
        self.with_obj(|env, _obj| {
            let result = JPollResult::from_env(env, result_ref.as_obj())?;
            get_poll_result(env, result).map(|_| {})
        })?;
        // Query the system-cached device name and update local_name
        self.with_obj(|_env, obj| -> std::result::Result<(), Error> {
            if let Ok(Some(name)) = obj.get_device_name() {
                let mut guard = self.shared.lock().map_err(Into::<Error>::into)?;
                if let Some(ref mut props) = guard.properties {
                    props.local_name = Some(name);
                }
            }
            Ok(())
        })?;
        // Auto-negotiate maximum MTU (517) after connection
        let mtu_future = self.with_obj(|env, obj| {
            JSendFuture::try_from(JFuture::from_env(env, obj.request_mtu(517)?)?)
        })?;
        let mtu_result_ref = mtu_future.await?;
        self.with_obj(|env, _obj| -> Result<()> {
            let mtu_result = JPollResult::from_env(env, mtu_result_ref.as_obj())?;
            let mtu_obj = get_poll_result(env, mtu_result)?;
            let mtu_val = env.call_method(mtu_obj, "intValue", "()I", &[])?.i()?;
            self.mtu.store(mtu_val as u16, Ordering::Relaxed);
            Ok(())
        })?;
        Ok(())
    }

    async fn disconnect(&self) -> Result<()> {
        let future = self.with_obj(|env, obj| JSendFuture::try_from(obj.disconnect()?))?;