From 89f1a8380b418874a0315184d090d944563822a7 Mon Sep 17 00:00:00 2001
From: llbartekll <bartus000@gmail.com>
Date: Thu, 19 Sep 2024 14:12:36 +0200
Subject: [PATCH] savepoint

---
 .../RelayClientEndToEndTests.swift            | 42 +++++++++----------
 1 file changed, 21 insertions(+), 21 deletions(-)

diff --git a/Example/RelayIntegrationTests/RelayClientEndToEndTests.swift b/Example/RelayIntegrationTests/RelayClientEndToEndTests.swift
index 1dffb970..65501d1a 100644
--- a/Example/RelayIntegrationTests/RelayClientEndToEndTests.swift
+++ b/Example/RelayIntegrationTests/RelayClientEndToEndTests.swift
@@ -88,27 +88,27 @@ final class RelayClientEndToEndTests: XCTestCase {
         super.tearDown()
     }
 
-    func testSubscribe() {
-        relayA = makeRelayClient(prefix: "")
-
-        do {
-            try relayA.connect()
-        } catch {
-            XCTFail("Failed to connect: \(error)")
-        }
-
-        let subscribeExpectation = expectation(description: "subscribe call succeeds")
-        subscribeExpectation.assertForOverFulfill = true
-        relayA.socketConnectionStatusPublisher.sink { [weak self] status in
-            guard let self = self else {return}
-            if status == .connected {
-                Task(priority: .high) {  try await self.relayA.subscribe(topic: "ecb78f2df880c43d3418ddbf871092b847801932e21765b250cc50b9e96a9131") }
-                subscribeExpectation.fulfill()
-            }
-        }.store(in: &publishers)
-
-        wait(for: [subscribeExpectation], timeout: InputConfig.defaultTimeout)
-    }
+//    func testSubscribe() {
+//        relayA = makeRelayClient(prefix: "")
+//
+//        do {
+//            try relayA.connect()
+//        } catch {
+//            XCTFail("Failed to connect: \(error)")
+//        }
+//
+//        let subscribeExpectation = expectation(description: "subscribe call succeeds")
+//        subscribeExpectation.assertForOverFulfill = true
+//        relayA.socketConnectionStatusPublisher.sink { [weak self] status in
+//            guard let self = self else {return}
+//            if status == .connected {
+//                Task(priority: .high) {  try await self.relayA.subscribe(topic: "ecb78f2df880c43d3418ddbf871092b847801932e21765b250cc50b9e96a9131") }
+//                subscribeExpectation.fulfill()
+//            }
+//        }.store(in: &publishers)
+//
+//        wait(for: [subscribeExpectation], timeout: InputConfig.defaultTimeout)
+//    }
 
     func testEndToEndPayload() {
         relayA = makeRelayClient(prefix: "⚽️ A ")