···

       
53
       
53
       
 
       
- `next(value)` emits a value on the sink

     

       
54
       
54
       
 
       
- `complete()` ends the source and completes the sink

     

       
55
       
55
       
 
       


     

       
56
       
56
       
-
       
The subscriber function also needs ot return a `teardown` function. This function

     

       
56
       
56
       
+
       
The subscriber function also needs to return a `teardown` function. This function

     

       
57
       
57
       
 
       
is called when either `complete()` is called and the source ends, or if the source

     

       
58
       
58
       
 
       
is being cancelled, since the sink unsubscribed.

     

       
59
       
59