如何在Android中使用RxJava2进行长时间运行的数据库操作，直到所有任务执行完毕并将数据插入数据库？

import io.reactivex.Observable;
import io.reactivex.schedulers.Schedulers;
import io.reactivex.android.schedulers.AndroidSchedulers;

// 定义数据模型
@Entity
public class DataEntity {
    // 定义实体类的属性
    // ...
}

// 定义数据访问对象（DAO）
@Dao
public interface DataDao {
    @Insert
    void insertData(DataEntity data);
    // 其他数据库操作方法
    // ...
}

// 创建数据库
@Database(entities = {DataEntity.class}, version = 1)
public abstract class AppDatabase extends RoomDatabase {
    public abstract DataDao dataDao();

    private static volatile AppDatabase INSTANCE;

    public static AppDatabase getInstance(Context context) {
        if (INSTANCE == null) {
            synchronized (AppDatabase.class) {
                if (INSTANCE == null) {
                    INSTANCE = Room.databaseBuilder(context.getApplicationContext(),
                            AppDatabase.class, "database-name")
                            .build();
                }
            }
        }
        return INSTANCE;
    }
}

// 在Activity或Fragment中执行数据库操作
public class MainActivity extends AppCompatActivity {
    private Disposable disposable;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        disposable = longRunningDatabaseOperation()
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(this::handleData, this::handleError);
    }

    @Override
    protected void onDestroy() {
        super.onDestroy();
        if (disposable != null && !disposable.isDisposed()) {
            disposable.dispose();
        }
    }

    private Observable<DataEntity> longRunningDatabaseOperation() {
        return Observable.create(emitter -> {
            // 长时间运行的数据库操作
            // 获取数据
            List<DataEntity> dataList = fetchDataFromSomewhere();
            
            // 插入数据到数据库
            AppDatabase.getInstance(getApplicationContext())
                    .dataDao()
                    .insertData(dataList);

            // 完成后通知数据已经插入完毕
            emitter.onNext(dataList);
            emitter.onComplete();
        });
    }

    private void handleData(List<DataEntity> dataList) {
        // 处理数据
        // 更新UI或其他操作
    }

    private void handleError(Throwable throwable) {
        // 处理错误
        // 提示用户或其他操作
    }
}