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.
valveOf(pipe) Go down the chain of valves until you find a valve of the given type. This is useful if you know there is a pipe you are looking for in the chain of valves.