···

       
48
       
48
       
 
       
let sourceOne = Wonka.fromArray([|1, 2, 3|]);

     

       
49
       
49
       
 
       
let sourceTwo = Wonka.fromArray([|4, 5, 6|]);

     

       
50
       
50
       
 
       


     

       
51
       
51
       
-
       
Wonka.combine(sourceOne, sourceTwo)

     

       
51
       
51
       
+
       
Wonka.combine(sourceOne)

     

       
52
       
52
       
+
       
  |> sourceTwo

     

       
52
       
53
       
 
       
  |> Wonka.subscribe((. (a, b)) => print_int(a + b));

     

       
53
       
54
       
 
       


     

       
54
       
55
       
 
       
/* Prints 56789 (1+4, 2+4, 3+4, 3+5, 3+6) to the console. */

     

···

       
113
       
113
       
 
       


     

       
114
       
114
       
 
       
```reason

     

       
115
       
115
       
 
       
let subject = Wonka.makeSubject();

     

       
116
       
116
       
-
       
let (source, next, complete) = subject;

     

       
116
       
116
       
+
       
let { source, next, complete } = subject;

     

       
117
       
117
       
 
       


     

       
118
       
118
       
 
       
/* This will push the values synchronously to any subscribers of source */

     

       
119
       
119
       
 
       
next(1);