我正在尝试将我的前端代码转换为 java 本机代码。但是如何转换以及我可以在 rxjava3 中使用的类似运算符有点困难。
Forntend rxjs 示例
createOrAlterTable$(dataType: string) {
return forkJoin(this.readTableFromBackend$(dataType),
this.readLastSyncFile$(), this.getUserData$())
.pipe(switchMap(combineresult => {
var sqlliteddl: any = combineresult[0];
var lastfv: any = combineresult[1];
var userDataFlag: any = combineresult[2];
let obslist$ = [];
...
...
let obseravel$ = this..createOrAlterTable(JSON.stringify(queryjson), type);
obslist$.push(obseravel$);
...
...
...
return forkJoin(obslist$);
}));
}
与上面相同,我想在使用 rxjava3 的 java 1.8 程序中实现。如何?
任何帮助都非常受欢迎。
谢谢。