Method notifications

src/droidplug/peripheral.rs:407–440

(&self)

    }

    async fn notifications(&self) -> Result<Pin<Box<dyn Stream<Item = ValueNotification> + Send>>> {
        use futures::stream::StreamExt;
        let shared = self.shared.clone();
        let stream = self.with_obj(|_env, obj| JSendStream::try_from(obj.get_notifications()?))?;
        let stream = stream
            .map(move |item| match item {
                Ok(item) => {
                    let env = global_jvm().get_env()?;
                    let item = item.as_obj();
                    let characteristic = JBluetoothGattCharacteristic::from_env(&env, item)?;
                    let uuid = characteristic.get_uuid()?;
                    let value = characteristic.get_value()?;
                    let service_uuid = shared
                        .lock()
                        .ok()
                        .and_then(|guard| {
                            guard
                                .services
                                .iter()
                                .find(|s| s.characteristics.iter().any(|c| c.uuid == uuid))
                                .map(|s| s.uuid)
                        })
                        .unwrap_or_default();
                    Ok(ValueNotification {
                        uuid,
                        service_uuid,
                        value,
                    })
                }
                Err(err) => Err(err),
            })
            .filter_map(|item| async { item.ok() });
        Ok(Box::pin(stream))
    }

    async fn read_rssi(&self) -> Result<i16> {
        let future = self.with_obj(|env, obj| {