如何使用RxJava和Lambda表达式在地图中一次插入两条记录

// 导入RxJava相关依赖
import io.reactivex.Observable;
import io.reactivex.Observer;
import io.reactivex.disposables.Disposable;

public class MapInsertExample {
    // 定义地图记录数据模型
    public static class MapRecord {
        private String location;
        private String description;

        public MapRecord(String location, String description) {
            this.location = location;
            this.description = description;
        }

        // 省略getter和setter方法
    }

    public static void main(String[] args) {
        // 创建Observable对象
        Observable<MapRecord> mapRecordObservable = Observable.create(emitter -> {
            // 发射两条记录
            emitter.onNext(new MapRecord("Location1", "Description1"));
            emitter.onNext(new MapRecord("Location2", "Description2"));
            emitter.onComplete();
        });

        // 使用Lambda表达式编写插入记录的逻辑
        mapRecordObservable.subscribe(record -> {
            // 执行插入记录的操作，可以是数据库操作、网络请求等
            System.out.println("插入记录：" + record.getLocation() + " - " + record.getDescription());
        });
    }
}