lib/junkie/pyload/observer.rb in junkie-0.1.2 vs lib/junkie/pyload/observer.rb in junkie-0.1.3
- old
+ new
@@ -33,9 +33,10 @@
@channels[:episodes].subscribe do |episode|
next unless episode.status == :resolved
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