同步SubmissionPublisher

import java.util.concurrent.Flow.*;
import java.util.concurrent.SubmissionPublisher;

public class SubmissionPublisherExample {
    public static void main(String[] args) {
        // 创建一个 SubmissionPublisher 实例
        SubmissionPublisher<String> publisher = new SubmissionPublisher<>();

        // 创建一个订阅者
        Subscriber<String> subscriber = new Subscriber<>() {
            private Subscription subscription;

            @Override
            public void onSubscribe(Subscription subscription) {
                this.subscription = subscription;
                subscription.request(1); // 请求一个数据项
            }

            @Override
            public void onNext(String item) {
                System.out.println("Received: " + item);
                subscription.request(1); // 处理完一个数据项后，再请求一个数据项
            }

            @Override
            public void onError(Throwable throwable) {
                throwable.printStackTrace();
            }

            @Override
            public void onComplete() {
                System.out.println("Done");
            }
        };

        // 订阅发布者
        publisher.subscribe(subscriber);

        // 发布数据
        publisher.submit("Hello");
        publisher.submit("World");

        // 关闭发布者
        publisher.close();
    }
}