Lines Matching defs:flow
435 // Only flow one buffer at a time.
602 // Otherwise we risk emitting data in the flow()
638 // 1. It is not flowing, as the flow mechanism will take
647 flow(stream);
675 // call read here would abort the flow and there's no other mechanism for
676 // continuing the flow if the stream consumer has just subscribed to the
799 // handler in flow(), but adding and removing repeatedly is
857 // Start the flow if it hasn't been started already.
998 // the upcoming resume will not flow.
1020 // We flow only if there is no one listening
1045 flow(stream);
1061 function flow(stream) {
1063 debug('flow', state.flowing);