commit 8c013553996facf545c3030a6581718dcba95cae · kitten.sh/wonka

kitten.sh / wonka

Mirror: 🎩 A tiny but capable push & pull stream library for TypeScript and Flow

fork atom

Fix share Pull signal blocker

kitten.sh 7 years ago 8c013553 308ec6d5

options

unified split

Changed files

+5 -2

src

callbag.re

+5 -2

src/callbag.re

···

       158
       158
        
                 state.talkback(End);

     

       159
       159
        
               };

     

       160
       160
        
             }

     

       161
       161
       -
             | Pull when !state.gotSignal => state.talkback(signal)

     

       162
       162
       -
             | _ => ()

     

       161
       161
       +
             | Pull when !state.gotSignal => {

     

       162
       162
       +
               state.gotSignal = true;

     

       163
       163
       +
               state.talkback(signal);

     

       164
       164
       +
             }

     

       165
       165
       +
             | Pull => ()

     

       163
       166
        
             }

     

       164
       167
        
           }));

     

       165
       168
        
         }