@@ -92,8 +92,8 @@ abstract class SignalState<T extends SignalView> extends State<T> {
9292 super .dispose ();
9393 }
9494
95- /// 过滤其他房间的信令
96- Stream < CallEvent > get sameRoomSignalStream => widget.callEventSubject.stream.where ((event) => LiveUtils .isSameRoom (event, roomID));
95+ Stream < CallEvent > get sameRoomSignalStream =>
96+ widget.callEventSubject.stream.where ((event) => LiveUtils .isSameRoom (event, roomID));
9797
9898 _onUpdateUserInfo (UserInfo ? info) {
9999 if (! mounted && null != info) return ;
@@ -102,12 +102,10 @@ abstract class SignalState<T extends SignalView> extends State<T> {
102102 });
103103 }
104104
105- /// 某些信令通过liveKit的监听
106105 _onStateDidUpdate (CallEvent event) {
107- Logger .print ("CallEvent : 当前 :$callState 收到 :$event " );
106+ Logger .print ("CallEvent current :$callState event :$event " );
108107 if (! mounted) return ;
109108
110- // ui 状态只有 呼叫,被呼叫,通话中,连接中
111109 if (event.state == CallState .call ||
112110 event.state == CallState .beCalled ||
113111 event.state == CallState .connecting ||
@@ -122,11 +120,11 @@ abstract class SignalState<T extends SignalView> extends State<T> {
122120 return ;
123121 }
124122 widget.onClose? .call ();
125- IMViews .showToast (sprintf (StrRes .otherCallHandle, [event.state == CallState .otherReject ? StrRes .rejectCall : StrRes .accept]));
123+ IMViews .showToast (
124+ sprintf (StrRes .otherCallHandle, [event.state == CallState .otherReject ? StrRes .rejectCall : StrRes .accept]));
126125 } else if (event.state == CallState .timeout) {
127126 widget.onClose? .call ();
128127 } else if (event.state == CallState .beAccepted) {
129- // 邀请对象比发起对象提前进入房间
130128 if (null != remoteParticipantTrack) {
131129 onParticipantConnected ();
132130 }
@@ -142,7 +140,6 @@ abstract class SignalState<T extends SignalView> extends State<T> {
142140 onTapHangup (false );
143141 }
144142
145- /// 发起者在对方为进入房间都是 等待状态
146143 onDail () async {
147144 if (widget.initState == CallState .call) {
148145 // callStateSubject.add(CallState.connecting);
@@ -159,19 +156,20 @@ abstract class SignalState<T extends SignalView> extends State<T> {
159156 }
160157
161158 onTapPickup () async {
162- Logger .print ('------------onTapPickup---------连接中-------- ' );
159+ Logger .print ('connecting ' );
163160 callStateSubject.add (CallState .connecting);
164161 certificate = await widget.onTapPickup! .call ();
165162 widget.onBindRoomID? .call (roomID = certificate.roomID! );
166163 await connect ();
167164 callStateSubject.add (CallState .calling);
168165 widget.onStartCalling? .call ();
169- Logger .print ('------------onTapPickup---------连接成功-------- ' );
166+ Logger .print ('connected ' );
170167 }
171168
172- /// [isPositive] 人为挂断行为
173169 onTapHangup (bool isPositive) async {
174- await widget.onTapHangup? .call (duration, isPositive).whenComplete (() => /*isPositive ? {} : */ widget.onClose? .call ());
170+ await widget.onTapHangup
171+ ? .call (duration, isPositive)
172+ .whenComplete (() => /*isPositive ? {} : */ widget.onClose? .call ());
175173 }
176174
177175 onTapCancel () async {
@@ -254,7 +252,8 @@ abstract class SignalState<T extends SignalView> extends State<T> {
254252 child: SizedBox (
255253 width: 120. w,
256254 height: 180. h,
257- child: ParticipantWidget .widgetFor (smallScreenIsRemote ? localParticipantTrack! : remoteParticipantTrack! ),
255+ child: ParticipantWidget .widgetFor (
256+ smallScreenIsRemote ? localParticipantTrack! : remoteParticipantTrack! ),
258257 ),
259258 onTap: () {
260259 if (remoteParticipantTrack != null ) {
0 commit comments