Bugfix

Author: janezkranjc

setup.py

@@ -19,7 +19,7 @@
 
 dist = setup(
     name='twitter-tap',
-    version='2.2.0',
+    version='2.2.1',
     author='Janez Kranjc',
     description='Collect tweets to a mongoDB using either the Twitter search API or the streaming API.',
     long_description=long_description,

twitter_tap/filer.py

@@ -24,7 +24,7 @@ def emit(self, dict_entry):
         text_to_wtite = json.dumps(dict_entry) + "\n"
         self.file.write(text_to_wtite)
         self.counter += 1
-        if self.counter > self.flush_every:
+        if self.counter % self.flush_every == 0:
             self.file.flush()
         if self.counter >= self.n:  # add condition  "if new day"
             self.close_file()