Remove NativeCall sort (#437)
This commit is contained in:
@@ -81,7 +81,6 @@ open class NativeCall(
|
|||||||
|
|
||||||
open fun nativeCall(requestMono: Mono<BlockchainOuterClass.NativeCallRequest>): Flux<BlockchainOuterClass.NativeCallReplyItem> {
|
open fun nativeCall(requestMono: Mono<BlockchainOuterClass.NativeCallRequest>): Flux<BlockchainOuterClass.NativeCallReplyItem> {
|
||||||
return nativeCallResult(requestMono)
|
return nativeCallResult(requestMono)
|
||||||
.sort { o1, o2 -> o1.id - o2.id }
|
|
||||||
.flatMapSequential(this::processCallResult)
|
.flatMapSequential(this::processCallResult)
|
||||||
.onErrorResume(this::processException)
|
.onErrorResume(this::processException)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user