lib/junkie/pyload/observer.rb in junkie-0.0.10 vs lib/junkie/pyload/observer.rb in junkie-0.0.11
- old
+ new
@@ -31,9 +31,10 @@
@channels[:episodes].subscribe do |episode|
next unless episode.status == :found
log.info("Got episode from Channel: #{episode}")
@found_episodes.push(episode)
+ stat_queued_episodes
end
end
# is a method that is called once from inside the reactor and allows us