0 people like it.

pipeline clip

1: 
2: 
3: 
4: 
5: 
6: 
7: 
8: 
9: 

pipeline {
    let inputQ = new PipelineInputQueue<_>(this.QueueLength, 0)
    let! rawDataQ = stage this.GetRawData inputQ
    let! recordsQ = stage this.ParseRawData rawDataQ
    let! conformedRecordsQ = stage this.ConformRecords recordsQ
    let! transformedDataQ = stage this.TransformRecord conformedRecordsQ
    do! sink this.Sink transformedDataQ     
    return inputQ
}
Raw view Test code New version

More information

Link:http://fssnip.net/8H
Posted:14 years ago
Author:
Tags:

This web site is created using F# and Suave web server. It is hosted on Azure and the source code is on GitHub. Contributions are welcome!

The first version of fssnip.net has been created by @tomaspetricek back in 2010. This web site is a new, open-source and contribution-friendly version.