@@ -650,14 +650,14 @@ class JoinedRoomProxy: JoinedRoomProxyProtocol {
650
650
}
651
651
652
652
/// Subscribe to call decline events from that rtc notification event.
653
- func callDeclineEventPublisher( notificationId rtcNotificationEventId : String ) -> AnyPublisher < RtcDeclinedEvent , Never > {
654
- let publisher = DeclineCallbackPublisher ( room: self , eventId : rtcNotificationEventId )
653
+ func callDeclineEventPublisher( notificationId rtcNotificationEventID : String ) -> AnyPublisher < RtcDeclinedEvent , Never > {
654
+ let publisher = DeclineCallbackPublisher ( room: self , eventID : rtcNotificationEventID )
655
655
return publisher. eraseToAnyPublisher ( )
656
656
}
657
657
658
- func subscribeToCallDeclineEvents( rtcNotificationEventId : String , listener: RoomCallDeclineListener ) -> Result < TaskHandle , RoomProxyError > {
658
+ func subscribeToCallDeclineEvents( rtcNotificationEventID : String , listener: RoomCallDeclineListener ) -> Result < TaskHandle , RoomProxyError > {
659
659
do {
660
- let handle = try room. subscribeToCallDeclineEvents ( rtcNotificationEventId: rtcNotificationEventId , listener: listener)
660
+ let handle = try room. subscribeToCallDeclineEvents ( rtcNotificationEventId: rtcNotificationEventID , listener: listener)
661
661
return . success( handle)
662
662
} catch {
663
663
MXLog . error ( " Failed observing rtc decline with error: \( error) " )
@@ -834,15 +834,15 @@ private final class RoomKnockRequestsListener: KnockRequestsListener {
834
834
835
835
final class RoomCallDeclineListener : CallDeclineListener {
836
836
private let onUpdateClosure : ( RtcDeclinedEvent ) -> Void
837
- private let notificationId : String
837
+ private let notificationID : String
838
838
839
- init ( notificationId : String , onUpdateClosure: @escaping ( RtcDeclinedEvent ) -> Void ) {
840
- self . notificationId = notificationId
839
+ init ( notificationID : String , onUpdateClosure: @escaping ( RtcDeclinedEvent ) -> Void ) {
840
+ self . notificationID = notificationID
841
841
self . onUpdateClosure = onUpdateClosure
842
842
}
843
843
844
844
func call( declinerUserId: String ) {
845
- onUpdateClosure ( . init( sender: declinerUserId, notificationEventId : notificationId ) )
845
+ onUpdateClosure ( . init( sender: declinerUserId, notificationEventID : notificationID ) )
846
846
}
847
847
}
848
848
@@ -852,10 +852,10 @@ struct DeclineCallbackPublisher: Publisher {
852
852
typealias Failure = Never
853
853
854
854
let room : JoinedRoomProxy
855
- let eventId : String
855
+ let eventID : String
856
856
857
857
func receive< S> ( subscriber: S ) where S: Subscriber , Never == S . Failure , RtcDeclinedEvent == S . Input {
858
- let subscription = Inner ( subscriber: subscriber, room: room, eventId : eventId )
858
+ let subscription = Inner ( subscriber: subscriber, room: room, eventID : eventID )
859
859
subscriber. receive ( subscription: subscription)
860
860
}
861
861
@@ -865,12 +865,12 @@ struct DeclineCallbackPublisher: Publisher {
865
865
private var handle : TaskHandle ?
866
866
private var listener : RoomCallDeclineListener ?
867
867
868
- init ( subscriber: S , room: JoinedRoomProxy , eventId : String ) {
868
+ init ( subscriber: S , room: JoinedRoomProxy , eventID : String ) {
869
869
self . subscriber = subscriber
870
- listener = RoomCallDeclineListener ( notificationId : eventId ) { [ weak self] ev in
870
+ listener = RoomCallDeclineListener ( notificationID : eventID ) { [ weak self] ev in
871
871
_ = self ? . subscriber? . receive ( ev)
872
872
}
873
- handle = try ? room. subscribeToCallDeclineEvents ( rtcNotificationEventId : eventId , listener: listener!) . get ( )
873
+ handle = try ? room. subscribeToCallDeclineEvents ( rtcNotificationEventID : eventID , listener: listener!) . get ( )
874
874
}
875
875
876
876
func request( _ demand: Subscribers . Demand ) {
0 commit comments