mirror of
https://github.com/fluencelabs/aqua-playground
synced 2025-04-25 13:22:23 +00:00
commit foldJoin.ts
This commit is contained in:
parent
b9cef0f8f9
commit
1407bb6307
@ -3,7 +3,7 @@
|
|||||||
* This file is auto-generated. Do not edit manually: changes may be erased.
|
* This file is auto-generated. Do not edit manually: changes may be erased.
|
||||||
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
|
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
|
||||||
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
|
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
|
||||||
* Aqua version: 0.5.3-SNAPSHOT
|
* Aqua version: 0.6.0-SNAPSHOT
|
||||||
*
|
*
|
||||||
*/
|
*/
|
||||||
import { Fluence, FluencePeer } from '@fluencelabs/fluence';
|
import { Fluence, FluencePeer } from '@fluencelabs/fluence';
|
||||||
@ -54,12 +54,18 @@ export function getTwoResults(...args: any) {
|
|||||||
(par
|
(par
|
||||||
(fold nodes n
|
(fold nodes n
|
||||||
(par
|
(par
|
||||||
(seq
|
(xor
|
||||||
(xor
|
(xor
|
||||||
(call n ("peer" "timestamp_sec") [] $res)
|
(call n ("peer" "timestamp_sec") [] $res)
|
||||||
(null)
|
(null)
|
||||||
)
|
)
|
||||||
(call node ("op" "noop") [])
|
(seq
|
||||||
|
(seq
|
||||||
|
(call -relay- ("op" "noop") [])
|
||||||
|
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
|
||||||
|
)
|
||||||
|
(call -relay- ("op" "noop") [])
|
||||||
|
)
|
||||||
)
|
)
|
||||||
(next n)
|
(next n)
|
||||||
)
|
)
|
||||||
@ -77,7 +83,7 @@ export function getTwoResults(...args: any) {
|
|||||||
)
|
)
|
||||||
(seq
|
(seq
|
||||||
(call -relay- ("op" "noop") [])
|
(call -relay- ("op" "noop") [])
|
||||||
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
|
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
@ -87,11 +93,11 @@ export function getTwoResults(...args: any) {
|
|||||||
)
|
)
|
||||||
(xor
|
(xor
|
||||||
(call %init_peer_id% ("callbackSrv" "response") [res-fix])
|
(call %init_peer_id% ("callbackSrv" "response") [res-fix])
|
||||||
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
|
|
||||||
)
|
|
||||||
)
|
|
||||||
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3])
|
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3])
|
||||||
)
|
)
|
||||||
|
)
|
||||||
|
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 4])
|
||||||
|
)
|
||||||
`
|
`
|
||||||
return callFunction(
|
return callFunction(
|
||||||
args,
|
args,
|
||||||
|
Loading…
x
Reference in New Issue
Block a user