···

       
85
       
85
       
 
       
const waitForArray = () => Promise.resolve([1, 2, 3]);

     

       
86
       
86
       
 
       


     

       
87
       
87
       
 
       
const source = make(observer => {

     

       
88
       
88
       
-
       
  const [next, complete] = observer;

     

       
88
       
88
       
+
       
  const { next, complete } = observer;

     

       
89
       
89
       
 
       
  let cancelled = false;

     

       
90
       
90
       
 
       


     

       
91
       
91
       
 
       
  waitForArray().then(arr => {

     
···

       
124
       
124
       
 
       
```typescript

     

       
125
       
125
       
 
       
import { makeSubject } from 'wonka'

     

       
126
       
126
       
 
       
const subject = Wonka.makeSubject();

     

       
127
       
127
       
-
       
const [source, next, complete] = subject;

     

       
127
       
127
       
+
       
const { source, next, complete } = subject;

     

       
128
       
128
       
 
       


     

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

     

       
130
       
130
       
 
       
next(1);