From 194b5372dc589929329133645f30c2638af8ccda Mon Sep 17 00:00:00 2001 From: sacOO7 Date: Fri, 14 Jun 2024 19:57:45 +0530 Subject: [PATCH] Fixed message_spec flaky test, implemented publish after subscribing to channel --- spec/acceptance/realtime/message_spec.rb | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/spec/acceptance/realtime/message_spec.rb b/spec/acceptance/realtime/message_spec.rb index 6ca7a884..e5eec8e7 100644 --- a/spec/acceptance/realtime/message_spec.rb +++ b/spec/acceptance/realtime/message_spec.rb @@ -586,11 +586,13 @@ def publish_and_check_extras(extras) let(:payload) { MessagePack.pack({ 'key' => random_str }) } it 'does not attempt to decrypt the message' do - unencrypted_channel_client1.publish 'example', payload - encrypted_channel_client2.subscribe do |message| - expect(message.data).to eql(payload) - expect(message.encoding).to be_nil - stop_reactor + wait_until(lambda { client.connection.state == :connected and other_client.connection.state == :connected }) do + encrypted_channel_client2.subscribe do |message| + expect(message.data).to eql(payload) + expect(message.encoding).to be_nil + stop_reactor + end + unencrypted_channel_client1.publish 'example', payload end end end