···

       
77
       
 
       
    "@types/jest": "^25.2.3",

     

       
78
       
 
       
    "@types/zen-observable": "^0.8.0",

     

       
79
       
 
       
    "babel-plugin-closure-elimination": "^1.3.1",

     

       
80
       
-
       
    "bs-platform": "^7.3.2",

     

       
81
       
 
       
    "callbag-from-iter": "^1.2.0",

     

       
82
       
 
       
    "callbag-iterate": "^1.0.0",

     

       
83
       
 
       
    "callbag-take": "^1.5.0",

     

···

       
77
       
 
       
    "@types/jest": "^25.2.3",

     

       
78
       
 
       
    "@types/zen-observable": "^0.8.0",

     

       
79
       
 
       
    "babel-plugin-closure-elimination": "^1.3.1",

     

       
80
       
+
       
    "bs-platform": "^8.0.2",

     

       
81
       
 
       
    "callbag-from-iter": "^1.2.0",

     

       
82
       
 
       
    "callbag-iterate": "^1.0.0",

     

       
83
       
 
       
    "callbag-take": "^1.5.0",

     

···

       
119
       
 
       
});

     

       
120
       
 
       


     

       
121
       
 
       
describe('fromList', () => {

     

       
122
       
-
       
  passesTrampoline(sources.fromList([1, [2]] as any));

     

       
123
       
-
       
  passesColdPull(sources.fromList([0] as any));

     

       
124
       
-
       
  passesActiveClose(sources.fromList([0] as any));

     

       
125
       
 
       
});

     

       
126
       
 
       


     

       
127
       
 
       
describe('fromValue', () => {

     

···

       
119
       
 
       
});

     

       
120
       
 
       


     

       
121
       
 
       
describe('fromList', () => {

     

       
122
       
+
       
  passesTrampoline(sources.fromList({hd: 1, tl: { hd: 2, tl: 0 } } as any));

     

       
123
       
+
       
  passesColdPull(sources.fromList({ hd: 0, tl: 0 } as any));

     

       
124
       
+
       
  passesActiveClose(sources.fromList({ hd: 1, tl: 0 } as any));

     

       
125
       
 
       
});

     

       
126
       
 
       


     

       
127
       
 
       
describe('fromValue', () => {

     

···

       
1
       
-
       
import { __ as block } from 'bs-platform/lib/es6/block';

     

       
2
       
 
       
import { talkbackPlaceholder } from './Wonka_helpers.bs';

     

       
3
       
 
       


     

       
4
       
 
       
import {

     
···

       
8
       
 
       


     

       
9
       
 
       
type talkbackCb = (tb: talkbackT) => void;

     

       
10
       
 
       


     

       
11
       
-
       
export const pull = (0 as any as talkbackT);

     

       
12
       
-
       
export const close = (1 as any as talkbackT);

     

       
13
       
 
       


     

       
14
       
-
       
export const start = <a>(tb: talkbackCb): signalT<a> => block(0, [tb]) as any;

     

       
15
       
-
       
export const push = <a>(x: a): signalT<a> => block(1, [x]) as any;

     

       
16
       
-
       
export const end = <a>(): signalT<a> => 0 as any;

     

       
17
       
 
       


     

       
18
       
 
       
export const isStart = <a>(s: signalT<a>) =>

     

       
19
       
-
       
  typeof s !== 'number' && (s as any).tag === 0;

     

       
20
       
 
       
export const isPush = <a>(s: signalT<a>) =>

     

       
21
       
-
       
  typeof s !== 'number' && (s as any).tag === 1;

     

       
22
       
 
       
export const isEnd = <a>(s: signalT<a>) =>

     

       
23
       
-
       
  typeof s === 'number' && (s as any) === 0;

     

       
24
       
 
       


     

       
25
       
 
       
export const unboxPush = <a>(s: signalT<a>): a | null =>

     

       
26
       
-
       
  isPush(s) ? (s as any)[0] : null;

     

       
27
       
 
       
export const unboxStart = <a>(s: signalT<a>): talkbackCb =>

     

       
28
       
-
       
  isStart(s) ? (s as any)[0] : (talkbackPlaceholder as any);

     

···

       
0
       
 
       

     

       
1
       
 
       
import { talkbackPlaceholder } from './Wonka_helpers.bs';

     

       
2
       
 
       


     

       
3
       
 
       
import {

     
···

       
7
       
 
       


     

       
8
       
 
       
type talkbackCb = (tb: talkbackT) => void;

     

       
9
       
 
       


     

       
10
       
+
       
export const pull: talkbackT = 0;

     

       
11
       
+
       
export const close: talkbackT = 1;

     

       
12
       
 
       


     

       
13
       
+
       
export const start = <a>(tb: talkbackCb): signalT<a> => ({TAG: 0, "_0": tb});

     

       
14
       
+
       
export const push = <a>(x: a): signalT<a> => ({TAG: 1, "_0": x});

     

       
15
       
+
       
export const end = <a>(): signalT<a> => 0;

     

       
16
       
 
       


     

       
17
       
 
       
export const isStart = <a>(s: signalT<a>) =>

     

       
18
       
+
       
  typeof s !== 'number' && s.TAG === 0;

     

       
19
       
 
       
export const isPush = <a>(s: signalT<a>) =>

     

       
20
       
+
       
  typeof s !== 'number' && s.TAG === 1;

     

       
21
       
 
       
export const isEnd = <a>(s: signalT<a>) =>

     

       
22
       
+
       
  typeof s === 'number' && s === 0;

     

       
23
       
 
       


     

       
24
       
 
       
export const unboxPush = <a>(s: signalT<a>): a | null =>

     

       
25
       
+
       
  isPush(s) ? s["_0"] : null;

     

       
26
       
 
       
export const unboxStart = <a>(s: signalT<a>): talkbackCb =>

     

       
27
       
+
       
  isStart(s) ? s["_0"] : (talkbackPlaceholder as any);

     

···

       
4
       
 
       
export type talkbackT = 0 | 1;

     

       
5
       
 
       


     

       
6
       
 
       
export type signalT<a> =

     

       
7
       
-
       
  | ({ tag: 0 } & [(talkback: talkbackT) => void])

     

       
8
       
-
       
  | ({ tag: 1 } & [a])

     

       
9
       
 
       
  | 0;

     

       
10
       
 
       


     

       
11
       
 
       
export interface observableSubscriptionT {

     

···

       
4
       
 
       
export type talkbackT = 0 | 1;

     

       
5
       
 
       


     

       
6
       
 
       
export type signalT<a> =

     

       
7
       
+
       
  | ({ TAG: 0, _0: (talkback: talkbackT) => void })

     

       
8
       
+
       
  | ({ TAG: 1, _0: a })

     

       
9
       
 
       
  | 0;

     

       
10
       
 
       


     

       
11
       
 
       
export interface observableSubscriptionT {

     

···

       
4309
       
 
       
  dependencies:

     

       
4310
       
 
       
    fast-json-stable-stringify "2.x"

     

       
4311
       
 
       


     

       
4312
       
-
       
bs-platform@^7.3.2:

     

       
4313
       
-
       
  version "7.3.2"

     

       
4314
       
-
       
  resolved "https://registry.yarnpkg.com/bs-platform/-/bs-platform-7.3.2.tgz#301f5c9b4e8cf5713cb60ca22e145e56e793affe"

     

       
4315
       
-
       
  integrity sha512-seJL5g4anK9la4erv+B2o2sMHQCxDF6OCRl9en3hbaUos/S3JsusQ0sPp4ORsbx5eXfHLYBwPljwKXlgpXtsgQ==

     

       
4316
       
 
       


     

       
4317
       
 
       
bser@2.1.1:

     

       
4318
       
 
       
  version "2.1.1"

     

···

       
4309
       
 
       
  dependencies:

     

       
4310
       
 
       
    fast-json-stable-stringify "2.x"

     

       
4311
       
 
       


     

       
4312
       
+
       
bs-platform@^8.0.2:

     

       
4313
       
+
       
  version "8.0.2"

     

       
4314
       
+
       
  resolved "https://registry.yarnpkg.com/bs-platform/-/bs-platform-8.0.2.tgz#8caf775c6c6fcde57ebb12f9efacd346951aeb45"

     

       
4315
       
+
       
  integrity sha512-2vHnyxCd4m5QYG/hxUGsevOqEkpqL+chmjV7I3yz9NT2lEtF6RafpUj30myQqdpDcIIhLja3PCkNq+ZVNSsXQA==

     

       
4316
       
 
       


     

       
4317
       
 
       
bser@2.1.1:

     

       
4318
       
 
       
  version "2.1.1"