Room + RxJava 2如何检查表中某列等于特定值的记录

@Dao
public interface MyDao {
    @Query("SELECT * FROM my_table WHERE my_column = :value")
    Flowable<List<MyEntity>> getRecordsWithValue(String value);
}

@Entity(tableName = "my_table")
public class MyEntity {
    // 定义表的列
    @PrimaryKey
    public int id;
    
    @ColumnInfo(name = "my_column")
    public String myColumn;
    
    // 其他列...
}

MyDatabase myDatabase = Room.databaseBuilder(getApplicationContext(), MyDatabase.class, "my-database").build();
MyDao myDao = myDatabase.myDao();

myDao.getRecordsWithValue("specific_value")
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(new Subscriber<List<MyEntity>>() {
        @Override
        public void onSubscribe(Subscription s) {
            s.request(Long.MAX_VALUE);
        }

        @Override
        public void onNext(List<MyEntity> entities) {
            // 处理查询结果
        }

        @Override
        public void onError(Throwable t) {
            // 处理错误情况
        }

        @Override
        public void onComplete() {
            // 查询完成
        }
    });