diff options
| author | Daniel Langesten <daniel.langest@gmail.com> | 2015-03-19 11:04:16 +0100 |
|---|---|---|
| committer | Daniel Langesten <daniel.langest@gmail.com> | 2015-03-19 11:04:16 +0100 |
| commit | 8a24169751948e0300e9b2bc13e5482cea546cec (patch) | |
| tree | 62c8e1aa9eb413ef247786b68fa03fa8f12fce2d /flow-cleaner.go | |
| parent | 2e95c44a37697f66e17524404ebd26b662450455 (diff) | |
added missing error check
Diffstat (limited to 'flow-cleaner.go')
| -rw-r--r-- | flow-cleaner.go | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/flow-cleaner.go b/flow-cleaner.go index f40f1c3..9e038cf 100644 --- a/flow-cleaner.go +++ b/flow-cleaner.go @@ -39,7 +39,10 @@ func processFromStdin(cfg *Config) { flogger.Println("Starting to process from stdin...") input := readFromStdin() rDatChan := parseRawData(input, cfg) - cleanFromStdin(rDatChan, cfg) + err := cleanFromStdin(rDatChan, cfg) + if err != nil { + flogger.Println("Failed to clean data:", err) + } flogger.Println("Finished processing from stdin!") } |