Skip to content

Commit 9f1410f

Browse files
committed
made new comp: split even odd
1 parent bc45dba commit 9f1410f

File tree

3 files changed

+59
-50
lines changed

3 files changed

+59
-50
lines changed

graphs/main.json

Lines changed: 36 additions & 50 deletions
Original file line numberDiff line numberDiff line change
@@ -12,26 +12,6 @@
1212
"outports": {},
1313
"groups": [],
1414
"processes": {
15-
"browser-app/averages_list_shjfx": {
16-
"component": "browser-app/averages_list",
17-
"metadata": {
18-
"label": "browser-app/averages_list",
19-
"x": -144,
20-
"y": 396,
21-
"width": 72,
22-
"height": 72
23-
}
24-
},
25-
"browser-app/split_even_odd_fp7v4": {
26-
"component": "browser-app/split_even_odd",
27-
"metadata": {
28-
"label": "browser-app/split_even_odd",
29-
"x": 72,
30-
"y": 396,
31-
"width": 72,
32-
"height": 72
33-
}
34-
},
3515
"browser-app/multiply_vbxt1": {
3616
"component": "browser-app/multiply",
3717
"metadata": {
@@ -72,12 +52,22 @@
7252
"height": 72
7353
}
7454
},
75-
"browser-app-1/generate_stream_of_random_integers_nlc4c": {
55+
"browser-app-1/generate_stream_of_random_integers_l52y1": {
7656
"component": "browser-app-1/generate_stream_of_random_integers",
7757
"metadata": {
7858
"label": "browser-app-1/generate_stream_of_random_integers",
79-
"x": 36,
80-
"y": 540,
59+
"x": -108,
60+
"y": 324,
61+
"width": 72,
62+
"height": 72
63+
}
64+
},
65+
"browser-app-1/split_even_odd_stream_wh4r4": {
66+
"component": "browser-app-1/split_even_odd_stream",
67+
"metadata": {
68+
"label": "browser-app-1/split_even_odd_stream",
69+
"x": 72,
70+
"y": 396,
8171
"width": 72,
8272
"height": 72
8373
}
@@ -86,60 +76,56 @@
8676
"connections": [
8777
{
8878
"src": {
89-
"process": "browser-app/averages_list_shjfx",
90-
"port": "output_list"
79+
"process": "browser-app/multiply_vbxt1",
80+
"port": "product"
9181
},
9282
"tgt": {
93-
"process": "browser-app/split_even_odd_fp7v4",
94-
"port": "in"
83+
"process": "browser-app/print_is_multiple_lists_e94nk",
84+
"port": "multiples_and_divisors_stream"
9585
}
9686
},
9787
{
9888
"src": {
99-
"process": "browser-app/split_even_odd_fp7v4",
100-
"port": "even"
89+
"process": "browser-app/DoSomething_opoqt",
90+
"port": "out"
10191
},
10292
"tgt": {
103-
"process": "browser-app/multiply_vbxt1",
104-
"port": "in"
93+
"process": "browser-app/print_next_and_mean_9pinh",
94+
"port": "input_stream"
10595
}
10696
},
10797
{
10898
"src": {
109-
"process": "browser-app/split_even_odd_fp7v4",
99+
"process": "browser-app-1/split_even_odd_stream_wh4r4",
110100
"port": "odd"
111101
},
112102
"tgt": {
113-
"process": "browser-app/DoSomething_opoqt",
103+
"process": "browser-app/multiply_vbxt1",
114104
"port": "in"
115-
}
105+
},
106+
"metadata": {}
116107
},
117108
{
118109
"src": {
119-
"process": "browser-app/multiply_vbxt1",
120-
"port": "product"
110+
"process": "browser-app-1/split_even_odd_stream_wh4r4",
111+
"port": "even"
121112
},
122113
"tgt": {
123-
"process": "browser-app/print_is_multiple_lists_e94nk",
124-
"port": "multiples_and_divisors_stream"
125-
}
114+
"process": "browser-app/DoSomething_opoqt",
115+
"port": "in"
116+
},
117+
"metadata": {}
126118
},
127119
{
128120
"src": {
129-
"process": "browser-app/DoSomething_opoqt",
121+
"process": "browser-app-1/generate_stream_of_random_integers_l52y1",
130122
"port": "out"
131123
},
132124
"tgt": {
133-
"process": "browser-app/print_next_and_mean_9pinh",
134-
"port": "input_stream"
135-
}
136-
},
137-
{
138-
"data": "test parameters",
139-
"tgt": {
140-
"process": "browser-app/averages_list_shjfx",
141-
"port": "input_stream"
142-
}
125+
"process": "browser-app-1/split_even_odd_stream_wh4r4",
126+
"port": "state"
127+
},
128+
"metadata": {}
143129
},
144130
{
145131
"data": "5",

spec/split_even_odd_stream.coffee

Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
noflo = require 'noflo'
2+
3+
exports.getComponent = ->
4+
c = new noflo.Component
5+
c.inPorts.add 'in', (event, payload) ->
6+
return unless event is 'data'
7+
# Do something with the packet, then
8+
c.outPorts.out.send payload
9+
c.inPorts.add 'func', (event, payload) ->
10+
return unless event is 'data'
11+
# Do something with the packet, then
12+
c.outPorts.out.send payload
13+
c.inPorts.add 'type', (event, payload) ->
14+
return unless event is 'data'
15+
# Do something with the packet, then
16+
c.outPorts.out.send payload
17+
c.inPorts.add 'state', (event, payload) ->
18+
return unless event is 'data'
19+
# Do something with the packet, then
20+
c.outPorts.out.send payload
21+
c.outPorts.add 'odd'
22+
c.outPorts.add 'even'
23+
c

spec/split_even_odd_stream.yaml

Whitespace-only changes.

0 commit comments

Comments
 (0)