如何将一个反应流中的另一个反应流作为if语句的结果使用

import java.util.concurrent.Flow.*;

// 定义反应流A，表示条件为真的情况
class StreamA implements Publisher<String> {
    @Override
    public void subscribe(Subscriber<? super String> subscriber) {
        // 发布A反应流的数据
        subscriber.onNext("条件为真的情况");
        subscriber.onComplete();
    }
}

// 定义反应流B，表示条件为假的情况
class StreamB implements Publisher<String> {
    @Override
    public void subscribe(Subscriber<? super String> subscriber) {
        // 发布B反应流的数据
        subscriber.onNext("条件为假的情况");
        subscriber.onComplete();
    }
}

// 定义条件流，用于判断条件，并选择输出A或B反应流
class ConditionalStream implements Publisher<Boolean> {
    @Override
    public void subscribe(Subscriber<? super Boolean> subscriber) {
        // 判断条件的逻辑，这里只是简单示例
        boolean condition = true;
        
        // 发布条件的结果
        subscriber.onNext(condition);
        subscriber.onComplete();
    }
}

// 主程序
public class Main {
    public static void main(String[] args) {
        // 创建A和B反应流实例
        StreamA streamA = new StreamA();
        StreamB streamB = new StreamB();
        
        // 创建条件流实例
        ConditionalStream conditionalStream = new ConditionalStream();
        
        // 订阅条件流，根据条件的结果选择输出A或B反应流
        conditionalStream.subscribe(new Subscriber<Boolean>() {
            @Override
            public void onSubscribe(Subscription subscription) {
                subscription.request(1);
            }

            @Override
            public void onNext(Boolean condition) {
                // 条件为真时输出A反应流，否则输出B反应流
                if (condition) {
                    streamA.subscribe(new Subscriber<String>() {
                        @Override
                        public void onSubscribe(Subscription subscription) {
                            subscription.request(1);
                        }

                        @Override
                        public void onNext(String data) {
                            System.out.println("输出A反应流：" + data);
                        }

                        @Override
                        public void onError(Throwable throwable) {
                        }

                        @Override
                        public void onComplete() {
                        }
                    });
                } else {
                    streamB.subscribe(new Subscriber<String>() {
                        @Override
                        public void onSubscribe(Subscription subscription) {
                            subscription.request(1);
                        }

                        @Override
                        public void onNext(String data) {
                            System.out.println("输出B反应流：" + data);
                        }

                        @Override
                        public void onError(Throwable throwable) {
                        }

                        @Override
                        public void onComplete() {
                        }
                    });
                }
            }

            @Override
            public void onError(Throwable throwable) {
            }

            @Override
            public void onComplete() {
            }
        });
    }
}