mirror of
https://github.com/fluencelabs/aqua-playground
synced 2025-07-30 21:22:02 +00:00
stream as argument in callback test
This commit is contained in:
7
aqua/examples/streamCallback.aqua
Normal file
7
aqua/examples/streamCallback.aqua
Normal file
@@ -0,0 +1,7 @@
|
||||
module Ret declares *
|
||||
|
||||
export someFunc
|
||||
|
||||
func someFunc(cb: []string -> ()):
|
||||
ifaces: *string
|
||||
cb(ifaces)
|
@@ -33,6 +33,7 @@ import { relays } from '../config';
|
||||
import {closuresCall} from "../examples/closures";
|
||||
import {topologyBug205} from "../compiled/examples/topology";
|
||||
import {streamCanCall} from "../examples/streamCan";
|
||||
import {streamCallbackCall} from "../examples/streamCallback";
|
||||
|
||||
var selfPeerId: string;
|
||||
var peer2: FluencePeer;
|
||||
@@ -139,6 +140,11 @@ describe('Testing examples', () => {
|
||||
expect(streamCanResult).toStrictEqual([["a"], ["b"], []]);
|
||||
});
|
||||
|
||||
it('streamCallback.aqua', async () => {
|
||||
let streamCallResult = await streamCallbackCall();
|
||||
expect(streamCallResult).toStrictEqual([]);
|
||||
});
|
||||
|
||||
it('topology.aqua', async () => {
|
||||
let topologyResult = await topologyCall(peer2);
|
||||
expect(topologyResult).toBe('finish');
|
||||
|
9
src/examples/streamCallback.ts
Normal file
9
src/examples/streamCallback.ts
Normal file
@@ -0,0 +1,9 @@
|
||||
import {someFunc} from "../compiled/examples/streamCallback";
|
||||
|
||||
export async function streamCallbackCall(): Promise<string[]> {
|
||||
return new Promise<string[]>((resolve, reject) => {
|
||||
someFunc((a: string[]) => {
|
||||
resolve(a);
|
||||
})
|
||||
});
|
||||
}
|
Reference in New Issue
Block a user