diff options
| -rw-r--r-- | feed/feed.go | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/feed/feed.go b/feed/feed.go index 25fc97d..7e0df4c 100644 --- a/feed/feed.go +++ b/feed/feed.go @@ -126,13 +126,14 @@ func (feed *Feed) Process(pState *state.ProcessState) { // Channel for receiving entry results. erChan := make(chan state.EntryResult) for i, entry := range feed.Entries { + e := entry // Process entry only if it was not downloaded before. - if !pState.DB.Exists(feed.Id, entry.Id) { - go feed.processEntry(entry, erChan) + if !pState.DB.Exists(feed.Id, e.Id) { + go feed.processEntry(e, erChan) processing += 1 } else { fmt.Printf("[%s][%s]: Already downloaded '%s' before\n", - feed.Id, entry.Id, entry.Title) + feed.Id, e.Id, e.Title) } // Process only `feed.Last` entries. |