如何在RxJava 2中实现将Observable发射的比特合并为整数的Observable？

嘿，这个场景用RxJava 2处理非常合适，完全不用像LiveData那样手动维护字符串缓冲区的状态，我给你两种实用的实现方式，你可以根据需求挑选：

方案一：用buffer操作符（直观易读，和你原LiveData逻辑对齐） #

buffer(31)会自动帮你收集上游发射的布尔值，每攒够31个就一次性发射一个包含这些元素的List。之后我们只需要把List转成二进制字符串再解析成整数就行，逻辑和你原来的LiveData实现几乎一致：

// 先拿到你的随机比特Observable
Observable<Boolean> randomBitObservable = ...;

Observable<Integer> randomIntegerObservable = randomBitObservable
        // 每收集31个比特就发射一次列表
        .buffer(31)
        // 过滤掉上游结束时可能剩下的不足31位的批次
        .filter(list -> list.size() == 31)
        // 把布尔列表拼接成二进制字符串（提前指定容量更高效）
        .map(list -> {
            StringBuilder sb = new StringBuilder(31);
            for (Boolean bit : list) {
                sb.append(bit ? '1' : '0');
            }
            return sb.toString();
        })
        // 将二进制字符串转为整数
        .map(bitString -> Integer.parseInt(bitString, 2));

方案二：buffer配合位运算（更高效，避免字符串开销） #

如果追求性能，直接用位运算累积数值比字符串拼接更高效，我们依然用buffer攒够31位，然后通过位运算直接计算出整数：

Observable<Boolean> randomBitObservable = ...;

Observable<Integer> randomIntegerObservable = randomBitObservable
        .buffer(31)
        .filter(list -> list.size() == 31)
        .map(list -> {
            int result = 0;
            for (Boolean bit : list) {
                // 左移一位腾出位置，再加上当前比特的0或1
                result = (result << 1) | (bit ? 1 : 0);
            }
            return result;
        });

这个写法既保留了buffer的简洁性，又比字符串方式更高效，非常推荐在性能敏感的场景下使用。

额外提示 #

• 如果是在Android环境下使用，记得根据线程需求加上调度器：比如上游比特生成在IO线程就加subscribeOn(Schedulers.io())，需要在主线程观察结果就加observeOn(AndroidSchedulers.mainThread())。
• 如果上游Observable可能提前结束，filter(list -> list.size() == 31)会自动过滤掉不完整的比特批次，避免生成无效的整数。

内容的提问来源于stack exchange，提问作者user4038217