@@ -112,7 +112,7 @@ public class LiveSessionCoordinator<R: RootRegistry>: ObservableObject {
112
112
$navigationPath. scan ( ( [ LiveNavigationEntry < R > ] ( ) , [ LiveNavigationEntry < R > ] ( ) ) , { ( $0. 1 , $1) } ) . sink { [ weak self] prev, next in
113
113
guard let self else { return }
114
114
Task {
115
- try await prev. last? . coordinator. disconnect ( )
115
+ try ? await prev. last? . coordinator. disconnect ( )
116
116
if prev. count > next. count {
117
117
let targetEntry = self . liveSocket!. getEntries ( ) [ next. count - 1 ]
118
118
next. last? . coordinator. join (
@@ -213,7 +213,7 @@ public class LiveSessionCoordinator<R: RootRegistry>: ObservableObject {
213
213
. merging ( additionalHeaders ?? [ : ] ) { $1 }
214
214
215
215
if let socket {
216
- try await socket. shutdown ( )
216
+ try ? await socket. shutdown ( )
217
217
}
218
218
219
219
let adapter = ReconnectStrategyAdapter ( self . configuration. reconnectBehavior)
@@ -336,7 +336,7 @@ public class LiveSessionCoordinator<R: RootRegistry>: ObservableObject {
336
336
private func disconnect( preserveNavigationPath: Bool = false ) async {
337
337
do {
338
338
for entry in self . navigationPath {
339
- try await entry. coordinator. disconnect ( )
339
+ try ? await entry. coordinator. disconnect ( )
340
340
if !preserveNavigationPath {
341
341
entry. coordinator. document = nil
342
342
}
@@ -360,7 +360,7 @@ public class LiveSessionCoordinator<R: RootRegistry>: ObservableObject {
360
360
361
361
self . liveReloadChannel = nil
362
362
363
- try await self . socket? . shutdown ( )
363
+ try ? await self . socket? . shutdown ( )
364
364
self . socket = nil
365
365
self . liveSocket = nil
366
366
self . state = . disconnected
0 commit comments