Skip to content

Commit

Permalink
Don't assert about shared publish routing distribution
Browse files Browse the repository at this point in the history
  • Loading branch information
Bret Ambrose committed Dec 19, 2024
1 parent 2abf568 commit f9d25b4
Showing 1 changed file with 0 additions and 6 deletions.
6 changes: 0 additions & 6 deletions test/test_mqtt5.py
Original file line number Diff line number Diff line change
Expand Up @@ -1009,8 +1009,6 @@ def test_operation_sub_unsub(self):
client.stop()
callbacks.future_stopped.result(TIMEOUT)

sub1_callbacks = False
sub2_callbacks = False
total_callbacks = 0
all_packets_received = Future()
mutex = Lock()
Expand All @@ -1020,7 +1018,6 @@ def subscriber1_callback(self, publish_received_data: mqtt5.PublishReceivedData)
self.mutex.acquire()
var = publish_received_data.publish_packet.payload
self.received_subscriptions[int(var)] = 1
self.sub1_callbacks = True
self.total_callbacks = self.total_callbacks + 1
if self.total_callbacks == 10:
self.all_packets_received.set_result(None)
Expand All @@ -1030,7 +1027,6 @@ def subscriber2_callback(self, publish_received_data: mqtt5.PublishReceivedData)
self.mutex.acquire()
var = publish_received_data.publish_packet.payload
self.received_subscriptions[int(var)] = 1
self.sub2_callbacks = True
self.total_callbacks = self.total_callbacks + 1
if self.total_callbacks == 10:
self.all_packets_received.set_result(None)
Expand Down Expand Up @@ -1154,8 +1150,6 @@ def test_operation_shared_subscription(self):
unsuback_packet = unsubscribe_future.result(TIMEOUT)
self.assertIsInstance(unsuback_packet, mqtt5.UnsubackPacket)

self.assertEqual(self.sub1_callbacks, True)
self.assertEqual(self.sub2_callbacks, True)
self.assertEqual(self.total_callbacks, 10)

for e in self.received_subscriptions:
Expand Down

0 comments on commit f9d25b4

Please sign in to comment.