RxAndroidBle如何读取来自多个服务的通知？

// 初始化RxAndroidBle库和蓝牙适配器
RxBleClient rxBleClient = RxBleClient.create(context);
RxBleDevice rxBleDevice = rxBleClient.getBleDevice(deviceMacAddress);

// 连接蓝牙设备
Disposable connectionDisposable = rxBleDevice.establishConnection(false)
    .subscribe(
        rxBleConnection -> {
            // 连接成功，发现设备的所有服务
            Disposable discoveryDisposable = rxBleConnection.discoverServices()
                .flatMap(rxBleDeviceServices -> Observable.fromIterable(rxBleDeviceServices.getBluetoothGattServices()))
                .subscribe(
                    rxBleDeviceService -> {
                        // 遍历服务列表，读取通知
                        Disposable notificationDisposable = rxBleConnection.setupNotification(rxBleDeviceService.getUuid())
                            .flatMap(notificationObservable -> notificationObservable)
                            .subscribe(
                                bytes -> {
                                    // 处理接收到的通知数据
                                    // 这里可以根据具体需求进行处理
                                },
                                throwable -> {
                                    // 处理通知读取错误
                                }
                            );

                        // 添加到CompositeDisposable，以便在需要时进行统一管理和取消订阅
                        compositeDisposable.add(notificationDisposable);
                    },
                    throwable -> {
                        // 处理服务发现错误
                    }
                );

            // 添加到CompositeDisposable
            compositeDisposable.add(discoveryDisposable);
        },
        throwable -> {
            // 处理设备连接错误
        }
    );

// 添加到CompositeDisposable
compositeDisposable.add(connectionDisposable);