将subscribe的返回类型Map到其他类型

u4dcyp6a  于 2021-06-30  发布在  Java
关注(0)|答案(0)|浏览(216)

在rxjava中Map返回类型

@Queue(ProductTopicConstants.DELETE_PRODUCT)
    public Single<String> Delete(String id) {
        LOG.info(String.format("Listener --> Delete the document from the database"));
        ProductSearchCriteria criteria = new ProductSearchCriteria();
        criteria.setId(id);
        Bson query = QueryBuilder.QueryBuilder(criteria, Bson.class).get(0);
        return  Single.fromPublisher(
                this.repository.getCollection(ProductConstrants.PRODUCT_COLLECTION_NAME, Product.class)
                        .deleteOne(query)).flatMap(item ->{
                            if(item.getDeletedCount() == 0)
                                return Single.just("Success");
                            else
                                return Single.just(id);
        });
    }

现在返回类型是一次性类型,是否可以转换为其他类型,例如 Single<String> 我试过了 flatMap 以及 MAP ,但当我订阅该方法时,它会再次转换为一次性的

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题