@@ -32,7 +32,7 @@ class Signaling {
3232
3333 final JsonEncoder _encoder = JsonEncoder ();
3434 final String _selfId = randomNumeric (6 );
35- late SimpleWebSocket _socket;
35+ late SimpleWebSocket ? _socket;
3636 var _sessionId;
3737 final _host;
3838 final _port = 8086 ;
@@ -63,7 +63,7 @@ class Signaling {
6363 _peerConnections.forEach ((key, pc) {
6464 pc.close ();
6565 });
66- if ( _socket != null ) _socket .close ();
66+ _socket? .close ();
6767 }
6868
6969 void switchCamera () {
@@ -228,25 +228,25 @@ class Signaling {
228228 }
229229 }
230230
231- _socket.onOpen = () {
231+ _socket? .onOpen = () {
232232 print ('onOpen' );
233233 onStateChange? .call (SignalingState .ConnectionOpen );
234234 _send ('new' ,
235235 {'name' : 'dart_webrtc' , 'id' : _selfId, 'user_agent' : 'broswer' });
236236 };
237237
238- _socket.onMessage = (message) {
238+ _socket? .onMessage = (message) {
239239 print ('Received data: ' + message);
240240 var decoder = JsonDecoder ();
241241 onMessage.call (decoder.convert (message));
242242 };
243243
244- _socket.onClose = (int code, String reason) {
244+ _socket? .onClose = (int code, String reason) {
245245 print ('Closed by server [$code => $reason ]!' );
246246 onStateChange? .call (SignalingState .ConnectionClosed );
247247 };
248248
249- await _socket.connect ();
249+ await _socket? .connect ();
250250 }
251251
252252 Future <MediaStream > createStream (media, user_screen) async {
@@ -291,7 +291,7 @@ class Signaling {
291291 'to' : id,
292292 'from' : _selfId,
293293 'candidate' : {
294- 'sdpMLineIndex' : candidate.sdpMlineIndex ,
294+ 'sdpMLineIndex' : candidate.sdpMLineIndex ,
295295 'sdpMid' : candidate.sdpMid,
296296 'candidate' : candidate.candidate,
297297 },
@@ -377,6 +377,6 @@ class Signaling {
377377 var request = {};
378378 request['type' ] = event;
379379 request['data' ] = data;
380- _socket.send (_encoder.convert (request));
380+ _socket? .send (_encoder.convert (request));
381381 }
382382}
0 commit comments