@@ -26,6 +26,7 @@ public class WebSocketTransport {
2626 public static var provider : ApolloWebSocketClient . Type = ApolloWebSocket . self
2727 public weak var delegate : WebSocketTransportDelegate ?
2828
29+ let connectOnInit : Bool
2930 let reconnect : Atomic < Bool >
3031 var websocket : ApolloWebSocketClient
3132 let error : Atomic < Error ? > = Atomic ( nil )
@@ -112,6 +113,7 @@ public class WebSocketTransport {
112113 reconnect: Bool = true ,
113114 reconnectionInterval: TimeInterval = 0.5 ,
114115 allowSendingDuplicates: Bool = true ,
116+ connectOnInit: Bool = true ,
115117 connectingPayload: GraphQLMap ? = [ : ] ,
116118 requestCreator: RequestCreator = ApolloRequestCreator ( ) ) {
117119 self . connectingPayload = connectingPayload
@@ -123,9 +125,12 @@ public class WebSocketTransport {
123125 self . websocket = WebSocketTransport . provider. init ( request: request, protocols: protocols)
124126 self . clientName = clientName
125127 self . clientVersion = clientVersion
128+ self . connectOnInit = connectOnInit
126129 self . addApolloClientHeaders ( to: & self . websocket. request)
127130 self . websocket. delegate = self
128- self . websocket. connect ( )
131+ if connectOnInit {
132+ self . websocket. connect ( )
133+ }
129134 self . websocket. callbackQueue = processingQueue
130135 }
131136
0 commit comments