Skip to content

Commit e6634c2

Browse files
authored
Merge pull request #235 from erikreed/persisted
Correctly spell persisted
2 parents fd66174 + e050fa0 commit e6634c2

File tree

3 files changed

+6
-3
lines changed

3 files changed

+6
-3
lines changed

examples/chatserver/settings.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -98,7 +98,7 @@
9898
# URL that distinguishes websocket connections from normal requests
9999
WEBSOCKET_URL = '/ws/'
100100

101-
# Set the number of seconds each message shall persited
101+
# Set the number of seconds each message shall be persisted
102102
WS4REDIS_EXPIRE = 3600
103103

104104
WS4REDIS_HEARTBEAT = '--heartbeat--'

ws4redis/subscriber.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ def set_pubsub_channels(self, request, channels):
4848
for key in self._get_message_channels(request=request, facility=facility, **audience):
4949
self._subscription.subscribe(key)
5050

51-
def send_persited_messages(self, websocket):
51+
def send_persisted_messages(self, websocket):
5252
"""
5353
This method is called immediately after a websocket is openend by the client, so that
5454
persisted messages can be sent back to the client upon connection.
@@ -58,6 +58,9 @@ def send_persited_messages(self, websocket):
5858
if message:
5959
websocket.send(message)
6060

61+
# for backwards compatibility: remove on major version upgrade (v1)
62+
send_persited_messages = send_persisted_messages
63+
6164
def get_file_descriptor(self):
6265
"""
6366
Returns the file descriptor used for passing to the select call when listening

ws4redis/wsgi_server.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,7 @@ def __call__(self, environ, start_response):
119119
redis_fd = subscriber.get_file_descriptor()
120120
if redis_fd:
121121
listening_fds.append(redis_fd)
122-
subscriber.send_persited_messages(websocket)
122+
subscriber.send_persisted_messages(websocket)
123123
recvmsg = None
124124
while websocket and not websocket.closed:
125125
ready = self.select(listening_fds, [], [], 4.0)[0]

0 commit comments

Comments
 (0)