如何在安卓系统的RxJava中通过flatmap发送一个自定义的一次性物品？

public class CustomItem implements Disposable {
    // 自定义一次性物品的属性和方法

    @Override
    public void dispose() {
        // 释放资源的操作
    }

    @Override
    public boolean isDisposed() {
        // 判断资源是否已释放的操作
        return false;
    }
}

Observable<CustomItem> customItemObservable = Observable.create(new ObservableOnSubscribe<CustomItem>() {
    @Override
    public void subscribe(ObservableEmitter<CustomItem> emitter) throws Exception {
        // 创建并发送自定义的一次性物品
        CustomItem customItem = new CustomItem();
        emitter.onNext(customItem);
        emitter.onComplete();
    }
});

customItemObservable.flatMap(new Function<CustomItem, ObservableSource<?>>() {
    @Override
    public ObservableSource<?> apply(CustomItem customItem) throws Exception {
        // 在这里进行自定义一次性物品的操作
        return Observable.just("操作完成");
    }
}).subscribe(new Consumer<Object>() {
    @Override
    public void accept(Object result) throws Exception {
        // 处理操作结果
        System.out.println(result);
    }
});