From 274407346aa2db1b751f5e5fe11ab0d8bbe9314c Mon Sep 17 00:00:00 2001 From: Harmon Date: Sun, 1 Jan 2023 10:44:20 -0600 Subject: [PATCH] Return base class method value in _process_data method for streaming --- tweepy/asynchronous/streaming.py | 2 +- tweepy/streaming.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/tweepy/asynchronous/streaming.py b/tweepy/asynchronous/streaming.py index 3adc363..4c4dbe9 100644 --- a/tweepy/asynchronous/streaming.py +++ b/tweepy/asynchronous/streaming.py @@ -637,7 +637,7 @@ class AsyncStreamingClient(AsyncBaseClient, AsyncBaseStream): else: return StreamRule(value=data["value"], id=data["id"]) else: - super()._process_data(data, data_type=data_type) + return super()._process_data(data, data_type=data_type) async def add_rules(self, add, **params): """add_rules(add, *, dry_run) diff --git a/tweepy/streaming.py b/tweepy/streaming.py index 3098ab1..39a6db7 100644 --- a/tweepy/streaming.py +++ b/tweepy/streaming.py @@ -645,7 +645,7 @@ class StreamingClient(BaseClient, BaseStream): else: return StreamRule(value=data["value"], id=data["id"]) else: - super()._process_data(data, data_type=data_type) + return super()._process_data(data, data_type=data_type) def add_rules(self, add, **params): """add_rules(add, *, dry_run) -- 2.25.1