File tree Expand file tree Collapse file tree 2 files changed +14
-3
lines changed
Sources/ParseSwift/LiveQuery Expand file tree Collapse file tree 2 files changed +14
-3
lines changed Original file line number Diff line number Diff line change @@ -53,6 +53,9 @@ extension LiveQuerySocket {
53
53
. encode ( StandardMessage ( operation: . connect,
54
54
additionalProperties: true ) )
55
55
guard let encodedAsString = String ( data: encoded, encoding: . utf8) else {
56
+ let error = ParseError ( code: . unknownError,
57
+ message: " Couldn't encode connect message: \( encoded) " )
58
+ completion ( error)
56
59
return
57
60
}
58
61
task. send ( . string( encodedAsString) ) { error in
Original file line number Diff line number Diff line change @@ -502,17 +502,25 @@ extension ParseLiveQuery {
502
502
return
503
503
}
504
504
if isSocketEstablished {
505
- try ? URLSession . liveQuery. connect ( task: self . task) { error in
506
- if error == nil {
507
- self . isConnecting = true
505
+ do {
506
+ try URLSession . liveQuery. connect ( task: self . task) { error in
507
+ if error == nil {
508
+ self . isConnecting = true
509
+ }
508
510
}
511
+ completion ( nil )
512
+ } catch {
513
+ completion ( error)
509
514
}
510
515
} else {
511
516
self . synchronizationQueue
512
517
. asyncAfter ( deadline: . now( ) + DispatchTimeInterval
513
518
. seconds ( reconnectInterval) ) {
514
519
self . createTask ( )
515
520
self . attempts += 1
521
+ let error = ParseError ( code: . unknownError,
522
+ message: " Attempted to open socket \( self . attempts) " )
523
+ completion ( error)
516
524
}
517
525
}
518
526
}
You can’t perform that action at this time.
0 commit comments