Skip to content
This repository was archived by the owner on Feb 21, 2023. It is now read-only.

Commit de40317

Browse files
author
Stephan Meier
committed
add combined sync + async callback test
1 parent 2a53f06 commit de40317

File tree

1 file changed

+12
-1
lines changed

1 file changed

+12
-1
lines changed

tests/test_pubsub.py

Lines changed: 12 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -271,7 +271,7 @@ def message_handler(self, message):
271271
self.message = message
272272

273273
async def async_message_handler(self, message):
274-
self.message = message
274+
self.async_message = message
275275

276276
async def test_published_message_to_channel(self, r):
277277
p = r.pubsub()
@@ -320,7 +320,18 @@ async def test_channel_async_message_handler(self, r):
320320
assert await wait_for_message(p) is None
321321
assert await r.publish("foo", "test message") == 1
322322
assert await wait_for_message(p) is None
323+
assert self.async_message == make_message("message", "foo", "test message")
324+
325+
async def test_channel_sync_async_message_handler(self, r):
326+
p = r.pubsub(ignore_subscribe_messages=True)
327+
await p.subscribe(foo=self.message_handler)
328+
await p.subscribe(bar=self.async_message_handler)
329+
assert await wait_for_message(p) is None
330+
assert await r.publish("foo", "test message") == 1
331+
assert await r.publish("bar", "test message 2") == 1
332+
assert await wait_for_message(p) is None
323333
assert self.message == make_message("message", "foo", "test message")
334+
assert self.async_message == make_message("message", "bar", "test message 2")
324335

325336
async def test_pattern_message_handler(self, r):
326337
p = r.pubsub(ignore_subscribe_messages=True)

0 commit comments

Comments
 (0)