kernel 1.1.0

Abstract Reactive Streams
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54

system "l core.q"

system "d .net"

/Reconnect timeout in ms
reConnTO:200

/CallBack function to retrieve previous data
getData:{()}
/Remote function name to call on update data
updFunc:`upd
/Remote function name to call on EOD
eodFunc:`eod

/Port listen to
listen:0

/FrontEnd Address
fea:`

/Mode to operate: 0 - master, 1 - slave.
mode:0

/FrontEnd handle
feh:-1

/List of subscribed user hanlers
suh:()

swmode:{mode::x; if [not[x]&feh<>-1; hclose feh; feh::-1]}

sub:{suh::suh union .z.w; getData x}

pub:{{.a[{neg[y] (updFunc;x)};(x;y);{}]}[x] peach suh}

.z.pc:{suh::suh except x; if [feh=x; feh::-1]; x}

eod:{{.a[{y ""; y (eodFunc;x)};(x;y);{}]}[x] peach suh}

netinit:{system "p ",string listen}

system "d ."

tryreconn:{
    if [.net.mode & .net.feh=-1;
        @[{.net.feh::hopen (.net.fea;.net.reConnTO); upd each .net.feh (`.net.sub;.core.seq)};
            0b;
            {if [.net.feh<>-1; hclose .net.feh; .net.feh::-1]}]
        ];
    }

tryeod:{ if [.core.geneod&not[.net.mode]&.core.eodtime="v"$.z.T; eod[.z.D]] }