{"id":1274,"date":"2018-09-17T19:07:31","date_gmt":"2018-09-17T18:07:31","guid":{"rendered":"https:\/\/solidt.eu\/site\/?p=1274"},"modified":"2018-09-17T19:08:23","modified_gmt":"2018-09-17T18:08:23","slug":"callbag-source-for-source-source-as-trigger-for-another-one","status":"publish","type":"post","link":"https:\/\/solidt.eu\/site\/callbag-source-for-source-source-as-trigger-for-another-one\/","title":{"rendered":"Callbag source for source (source as trigger for another one)"},"content":{"rendered":"<pre class=\"lang:js decode:true\">import { MessageType } from \"..\/enums\";\r\n\r\nexport let sourceForSource = (sourceA: Function, sourceB: Function) =&gt; {\r\n    return (start: number, sink: any) =&gt; {\r\n        if (start !== MessageType.START) return;\r\n        let talkbackA : Function, talkbackB : Function;\r\n        sourceA(MessageType.START, (t: number, data: any) =&gt; {\r\n            if (t === MessageType.START) {\r\n                talkbackA = data;\r\n            }\r\n            if (t === MessageType.DATA) {\r\n                sourceB(MessageType.START, (t2: number, data2: any) =&gt; {\r\n                    if (t2 === MessageType.START) {\r\n                        talkbackB = data2;\r\n                    }\r\n                    if (t2 === MessageType.DATA) {\r\n                        sink(t2, data2);\r\n                    }\r\n                });\r\n            }\r\n        });\r\n        sink(MessageType.START, (t: number) =&gt; {\r\n            if (t === MessageType.END) {\r\n                if (talkbackB) {\r\n                    talkbackB(MessageType.END);\r\n                }\r\n                if (talkbackA) {\r\n                    talkbackA(MessageType.END);\r\n                }\r\n            }\r\n        });\r\n    };\r\n}\r\n<\/pre>\n<pre class=\"lang:js decode:true \" title=\"usage\">pipe(\r\n    sourceForSource(interval(1000), fromCsvFile(\".\/BaggingInstructionTemplate.csv\", { delimiter: ',' })),\r\n    filter((d: any) =&gt; parseInt(d[1]) &gt; 40),\r\n    take(8),\r\n    map((r: any) =&gt; [r[0], r[1]]),\r\n    forEach((x: any) =&gt; console.log(x))\r\n)<\/pre>\n<p>&nbsp;<\/p>\n","protected":false},"excerpt":{"rendered":"<p>import { MessageType } from &#8220;..\/enums&#8221;; export let sourceForSource = (sourceA: Function, sourceB: Function) =&gt; { return (start: number, sink: any) =&gt; { if (start !== MessageType.START) return; let talkbackA : Function, talkbackB : Function; sourceA(MessageType.START, (t: number, data: any) =&gt; { if (t === MessageType.START) { talkbackA = data; } if (t === MessageType.DATA) [&hellip;]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"inline_featured_image":false,"footnotes":""},"categories":[5],"tags":[],"class_list":["post-1274","post","type-post","status-publish","format-standard","hentry","category-javascript"],"_links":{"self":[{"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/posts\/1274","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/comments?post=1274"}],"version-history":[{"count":2,"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/posts\/1274\/revisions"}],"predecessor-version":[{"id":1276,"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/posts\/1274\/revisions\/1276"}],"wp:attachment":[{"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/media?parent=1274"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/categories?post=1274"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/tags?post=1274"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}