Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Allow multiple filters #148

Merged
merged 6 commits into from
Jan 13, 2020
Merged

Allow multiple filters #148

merged 6 commits into from
Jan 13, 2020

Conversation

jonasae
Copy link
Contributor

@jonasae jonasae commented Jan 8, 2020

🎩 What?

Modify subscription constructor to allow iterables in filter_by and apply all filters.

🤔 Why?

Current version only allows one filter.

🔗 Related issue

Solver #134

Copy link
Contributor

@antoniobusrod antoniobusrod left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

What do you think about documentation? I already started with the issue, maybe you find worthy next chunk.

diff --git a/rele/subscription.py b/rele/subscription.py
index 73f6b03..3c4c276 100644
--- a/rele/subscription.py
+++ b/rele/subscription.py
@@ -139,9 +139,9 @@ def sub(topic, prefix=None, suffix=None, filter_by=None):
     :param suffix: string An optional suffix to the subscription name.
                    Useful when you have two subscribers in the same project
                    that are subscribed to the same topic.
-    :param filter_by: function An optional function that
-                      filters the messages to be processed
-                      by the sub regarding their attributes.
+    :param filter_by: Union[function, list] An optional function or tuple of
+                      functions that filters the messages to be processed by
+                      the sub regarding their attributes.
     :return: :class:`~rele.subscription.Subscription`
     """
 
 

@jonasae
Copy link
Contributor Author

jonasae commented Jan 8, 2020

What do you think about documentation? I already started with the issue, maybe you find worthy next chunk.

diff --git a/rele/subscription.py b/rele/subscription.py
index 73f6b03..3c4c276 100644
--- a/rele/subscription.py
+++ b/rele/subscription.py
@@ -139,9 +139,9 @@ def sub(topic, prefix=None, suffix=None, filter_by=None):
     :param suffix: string An optional suffix to the subscription name.
                    Useful when you have two subscribers in the same project
                    that are subscribed to the same topic.
-    :param filter_by: function An optional function that
-                      filters the messages to be processed
-                      by the sub regarding their attributes.
+    :param filter_by: Union[function, list] An optional function or tuple of
+                      functions that filters the messages to be processed by
+                      the sub regarding their attributes.
     :return: :class:`~rele.subscription.Subscription`
     """
 
 

Sure.

rele/subscription.py Show resolved Hide resolved
rele/subscription.py Outdated Show resolved Hide resolved
rele/subscription.py Show resolved Hide resolved
@jonasae jonasae merged commit 8c9afe5 into master Jan 13, 2020
csaroff pushed a commit to csaroff/rele that referenced this pull request Apr 19, 2023
* Allow iterable in filter_by.

* Add sad path test cases.

* Beat the linter.

* Update docs.

* Rename setter.

* Replace for loop.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants