Attempted fix for integration test failing on CI (#2024)

apollographql · Nov 9, 2021 · a8a35ae · a8a35ae
1 parent a1e857c
commit a8a35ae
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/Sources/ApolloWebSocket/WebSocketTransport.swift b/Sources/ApolloWebSocket/WebSocketTransport.swift
@@ -55,7 +55,7 @@ public class WebSocketTransport {
 
   private var subscribers = [String: (Result<JSONObject, Error>) -> Void]()
   private var subscriptions : [String: String] = [:]
-  private let processingQueue = DispatchQueue(label: "com.apollographql.WebSocketTransport")
+  let processingQueue = DispatchQueue(label: "com.apollographql.WebSocketTransport")
 
   private let sendOperationIdentifiers: Bool
   private let reconnectionInterval: TimeInterval

diff --git a/Tests/ApolloServerIntegrationTests/StarWarsSubscriptionTests.swift b/Tests/ApolloServerIntegrationTests/StarWarsSubscriptionTests.swift
@@ -334,9 +334,9 @@ class StarWarsSubscriptionTests: XCTestCase {
     // dispatched with a barrier flag to make sure
     // this is performed after subscription calls
     concurrentQueue.sync(flags: .barrier) {
-      // dispatched on the processing queue to make sure
+      // dispatched on the processing queue with barrier flag to make sure
       // this is performed after subscribers are processed
-      self.webSocketTransport.websocket.callbackQueue.async {
+      self.webSocketTransport.processingQueue.async(flags: .barrier) {
         _ = self.client.perform(mutation: CreateReviewForEpisodeMutation(episode: .empire, review: ReviewInput(stars: 5, commentary: "The greatest movie ever!")))
       }
     }