Skip to content

Commit

Permalink
fix Xcode 14.2 compiling
Browse files Browse the repository at this point in the history
  • Loading branch information
hiroshihorie committed Feb 6, 2024
1 parent be45083 commit c090646
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion Sources/LiveKit/Core/Engine+TransportDelegate.swift
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@ extension Engine: TransportDelegate {
removeWhen: { state, _ in state.connectionState == .disconnected })
{ [weak self] in
guard let self else { return }
_delegate.notifyAsync { await $0.engine(self, didAddTrack: track, rtpReceiver: rtpReceiver, stream: streams.first!) }
self._delegate.notifyAsync { await $0.engine(self, didAddTrack: track, rtpReceiver: rtpReceiver, stream: streams.first!) }
}
}
}
Expand Down
6 changes: 3 additions & 3 deletions Sources/LiveKit/Core/Engine.swift
Original file line number Diff line number Diff line change
Expand Up @@ -70,8 +70,8 @@ class Engine: Loggable {
lazy var subscriberDataChannel: DataChannelPairActor = .init(onDataPacket: { [weak self] dataPacket in
guard let self else { return }
switch dataPacket.value {
case let .speaker(update): _delegate.notifyAsync { await $0.engine(self, didUpdateSpeakers: update.speakers) }
case let .user(userPacket): _delegate.notifyAsync { await $0.engine(self, didReceiveUserPacket: userPacket) }
case let .speaker(update): self._delegate.notifyAsync { await $0.engine(self, didUpdateSpeakers: update.speakers) }
case let .user(userPacket): self._delegate.notifyAsync { await $0.engine(self, didReceiveUserPacket: userPacket) }
default: return
}
})
Expand Down Expand Up @@ -103,7 +103,7 @@ class Engine: Loggable {
self.log("connectionState: \(oldState.connectionState) -> \(newState.connectionState), reconnectMode: \(String(describing: newState.isReconnectingWithMode))")
}

_delegate.notifyAsync { await $0.engine(self, didMutateState: newState, oldState: oldState) }
self._delegate.notifyAsync { await $0.engine(self, didMutateState: newState, oldState: oldState) }

// execution control
self._blockProcessQueue.async { [weak self] in
Expand Down

0 comments on commit c090646

Please sign in to comment.