summaryrefslogtreecommitdiff
path: root/src/couch/feedreader.py
diff options
context:
space:
mode:
authorVictor Näslund <victor@sunet.se>2022-11-02 15:31:23 +0100
committerVictor Näslund <victor@sunet.se>2022-11-02 15:31:23 +0100
commit8baecf339e8061160bee519e87ffe837d1525c18 (patch)
tree22664c10f22382b1d4647b5f2e96bcea4220d879 /src/couch/feedreader.py
parentffb26f4a81a9ca61c4105df037f7e1beb8dc5fb0 (diff)
more freshup
Diffstat (limited to 'src/couch/feedreader.py')
-rw-r--r--src/couch/feedreader.py8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/couch/feedreader.py b/src/couch/feedreader.py
index 98401ab..aac51d3 100644
--- a/src/couch/feedreader.py
+++ b/src/couch/feedreader.py
@@ -11,7 +11,7 @@ class BaseFeedReader:
self.db = db
return self
- def on_message(self, message):
+ def on_message(self, message: str) -> None:
"""
Callback method that is called when change
message is received from couchdb.
@@ -22,14 +22,14 @@ class BaseFeedReader:
raise NotImplementedError()
- def on_close(self):
+ def on_close(self) -> None:
"""
Callback method that is received when connection
is closed with a server. By default, does nothing.
"""
pass
- def on_heartbeat(self):
+ def on_heartbeat(self) -> None:
"""
Callback method invoked when a hearbeat (empty line) is received
from the _changes stream. Override this to purge the reader's internal
@@ -48,5 +48,5 @@ class SimpleFeedReader(BaseFeedReader):
self.callback = callback
return super(SimpleFeedReader, self).__call__(db)
- def on_message(self, message) -> None:
+ def on_message(self, message: str) -> None:
self.callback(message, db=self.db)