Module iopipe.valve

Valve mechanism to allow manipulation of wrapped iopipe pieces.


holdingLoop(chain)Create an auto-flushing valve loop. This is for use with a chain where the next valve is a holding valve. What this does is automatically run the outlet of the holding valve so it seamlessly flushes all data when required.
holdingValve(chain)Create a valve that uses a holding location to pass data from the inlet to the outlet.
push(c)Convenience mechanism to wrap a specified output pipeline with a holding loop. It avoids having to explicitly specify the loop begin and end.
simpleValve(chain)Create a simple valve in an iopipe chain.