如果一个已关闭，如何继续合并InputStreams的Flowable，RxJava 2.x

import io.reactivex.Flowable;
import io.reactivex.schedulers.Schedulers;

// 创建多个InputStreams的列表
List<InputStream> inputStreams = new ArrayList<>();
inputStreams.add(inputStream1);
inputStreams.add(inputStream2);
// ...

// 将每个InputStream转换为Flowable，并使用concat操作符连接它们
Flowable<Byte> mergedFlowable = Flowable.concat(
        inputStreams.stream()
                .filter(inputStream -> !isClosed(inputStream)) // 过滤已关闭的InputStream
                .map(inputStream -> Flowable.fromIterable(readBytes(inputStream)))
                .collect(Collectors.toList())
);

// 处理合并后的Flowable
mergedFlowable
        .observeOn(Schedulers.io())
        .subscribe(byteData -> {
            // 处理每个字节数据
        });

// 检查InputStream是否已关闭
private boolean isClosed(InputStream inputStream) {
    try {
        inputStream.available(); // 如果已关闭，将抛出IOException
        return false; // 未关闭
    } catch (IOException e) {
        return true; // 已关闭
    }
}

// 从InputStream读取字节数据
private List<Byte> readBytes(InputStream inputStream) throws IOException {
    List<Byte> byteList = new ArrayList<>();
    int byteData;
    while ((byteData = inputStream.read()) != -1) {
        byteList.add((byte) byteData);
    }
    return byteList;
}