Skip to content

Commit

Permalink
savepoint
Browse files Browse the repository at this point in the history
  • Loading branch information
llbartekll committed Sep 19, 2024
1 parent 2225474 commit 89f1a83
Showing 1 changed file with 21 additions and 21 deletions.
42 changes: 21 additions & 21 deletions Example/RelayIntegrationTests/RelayClientEndToEndTests.swift
Original file line number Diff line number Diff line change
Expand Up @@ -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 ")
Expand Down

0 comments on commit 89f1a83

Please sign in to comment.