diff --git a/postgresql_watcher/watcher.py b/postgresql_watcher/watcher.py
index 4895e15..2f5d0ee 100644
--- a/postgresql_watcher/watcher.py
+++ b/postgresql_watcher/watcher.py
@@ -87,7 +87,6 @@ def create_subscriber_process(
         )
         if start_process:
             p.start()
-        self.should_reload()
         return p
 
     def set_update_callback(self, fn_name: Callable):
@@ -113,7 +112,7 @@ def update(self):
 
     def should_reload(self):
         try:
-            if self.parent_conn.poll():
+            if self.parent_conn.poll(None):
                 message = self.parent_conn.recv()
                 print(f"message:{message}")
                 return True
diff --git a/tests/test_postgresql_watcher.py b/tests/test_postgresql_watcher.py
index 537805d..fa0356a 100644
--- a/tests/test_postgresql_watcher.py
+++ b/tests/test_postgresql_watcher.py
@@ -39,9 +39,6 @@ def test_pg_watcher_init(self):
     def test_update_pg_watcher(self):
         assert pg_watcher.update() is True
 
-    def test_not_reload(self):
-        assert not pg_watcher.should_reload()
-
     def test_default_update_callback(self):
         assert pg_watcher.update_callback() is None