diff --git a/core/src/main/java/org/web3j/protocol/rx/JsonRpc2_0Rx.java b/core/src/main/java/org/web3j/protocol/rx/JsonRpc2_0Rx.java
index a63731890..bc206efaa 100644
--- a/core/src/main/java/org/web3j/protocol/rx/JsonRpc2_0Rx.java
+++ b/core/src/main/java/org/web3j/protocol/rx/JsonRpc2_0Rx.java
@@ -108,18 +108,6 @@ public void call() {
                 filter.cancel();
             }
         }));
-        scheduledExecutorService.submit(new Runnable() {
-            @Override
-            public void run() {
-                filter.run(scheduledExecutorService, pollingInterval);
-            }
-        });
-        subscriber.add(Subscriptions.create(new Action0() {
-            @Override
-            public void call() {
-                filter.cancel();
-            }
-        }));
     }
 
     public Observable<Transaction>  transactionObservable(final long pollingInterval) {