rx-java创建两个文件并从字符串输入压缩它们

import io.reactivex.Observable;
import io.reactivex.Observer;
import io.reactivex.disposables.Disposable;

import java.io.File;
import java.io.FileOutputStream;
import java.util.zip.ZipEntry;
import java.util.zip.ZipOutputStream;

public class FileCompressionExample {
    public static void main(String[] args) {
        Observable<String> inputObservable = Observable.create(emitter -> {
            emitter.onNext("String 1"); // 发射第一个字符串输入
            emitter.onNext("String 2"); // 发射第二个字符串输入
            emitter.onComplete(); // 发射完成事件
        });

        inputObservable.subscribe(new Observer<String>() {
            @Override
            public void onSubscribe(Disposable d) {
                // 可选实现，当订阅时调用
            }

            @Override
            public void onNext(String s) {
                // 创建文件并写入字符串输入
                File file = new File(s + ".txt");
                try (FileOutputStream fos = new FileOutputStream(file)) {
                    fos.write(s.getBytes());
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }

            @Override
            public void onError(Throwable e) {
                // 可选实现，当发生错误时调用
            }

            @Override
            public void onComplete() {
                // 压缩文件
                try (ZipOutputStream zos = new ZipOutputStream(new FileOutputStream("compressed.zip"))) {
                    File[] files = new File[]{new File("String 1.txt"), new File("String 2.txt")};
                    byte[] buffer = new byte[1024];
                    for (File file : files) {
                        ZipEntry ze = new ZipEntry(file.getName());
                        zos.putNextEntry(ze);
                        try (FileInputStream fis = new FileInputStream(file)) {
                            int length;
                            while ((length = fis.read(buffer)) > 0) {
                                zos.write(buffer, 0, length);
                            }
                        }
                        zos.closeEntry();
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        });
    }
}