On Wed, May 14, 2008 at 9:19 PM, Ian S. Worthington <[EMAIL PROTECTED]> wrote: > I have a datastream that consists of blocks of data delimited by start and end > sequences that requires the processing of each block. > > At first I thought that seemed like a job for fromtarget/totarget, but I can't > figure out how I would reset the filters to allow second and subsequent blocks > to be processed.
If you need to process each block as an entity, you probably want a sipping pipeline. do forever 'peekto' 'callpipe (end \) *: | frtarget .. | totarget | process ... | *:' end The frtarget will drop all records upto the start marker, and totarget will sip upto the end marker. For plumbing that does not leak, you need to make sure it consumes at least some records, or you can sip forever on it... Rob
