在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
,但当我订阅该方法时,它会再次转换为一次性的
暂无答案!
目前还没有任何答案,快来回答吧!