next-coder
diff --git a/‎android/src/main/java/com/cloudwebrtc/webrtc/PeerConnectionObserver.java
Lines changed: 9 additions & 9 deletions b/‎android/src/main/java/com/cloudwebrtc/webrtc/PeerConnectionObserver.java
Lines changed: 9 additions & 9 deletions
diff --git a/‎common/darwin/Classes/FlutterRTCPeerConnection.m
Lines changed: 18 additions & 1 deletion b/‎common/darwin/Classes/FlutterRTCPeerConnection.m
Lines changed: 18 additions & 1 deletion
diff --git a/‎example/lib/src/loopback_sample.dart
Lines changed: 5 additions & 0 deletions b/‎example/lib/src/loopback_sample.dart
Lines changed: 5 additions & 0 deletions
@@ -498,16 +498,16 @@ public void onSignalingChange(PeerConnection.SignalingState signalingState) {
     sendEvent(params);
   }
 
-    @Override
-    public void onConnectionChange(PeerConnection.PeerConnectionState connectionState) {
-        Log.d(TAG, "onConnectionChange" + connectionState.name());
-        ConstraintsMap params = new ConstraintsMap();
-        params.putString("event", "peerConnectionState");
-        params.putString("state", connectionStateString(connectionState));
-        sendEvent(params);
-    }
+  @Override
+  public void onConnectionChange(PeerConnection.PeerConnectionState connectionState) {
+    Log.d(TAG, "onConnectionChange" + connectionState.name());
+    ConstraintsMap params = new ConstraintsMap();
+    params.putString("event", "peerConnectionState");
+    params.putString("state", connectionStateString(connectionState));
+    sendEvent(params);
+  }
 
-    @Nullable
+  @Nullable
   private String iceConnectionStateString(PeerConnection.IceConnectionState iceConnectionState) {
     switch (iceConnectionState) {
       case NEW:
 
@@ -253,6 +253,17 @@ - (NSString *)stringForSignalingState:(RTCSignalingState)state {
     return nil;
 }
 
+- (NSString *)stringForPeerConnectionState:(RTCPeerConnectionState)state {
+    switch (state) {
+        case RTCPeerConnectionStateNew: return @"new";
+        case RTCPeerConnectionStateConnecting: return @"connecting";
+        case RTCPeerConnectionStateConnected: return @"connected";
+        case RTCPeerConnectionStateDisconnected: return @"disconnected";
+        case RTCPeerConnectionStateFailed: return @"failed";
+        case RTCPeerConnectionStateClosed: return @"closed";
+    }
+    return nil;
+}
 
 /**
  * Parses the constraint keys and values of a specific JavaScript object into
@@ -493,7 +504,13 @@ - (void)peerConnection:(RTCPeerConnection*)peerConnection didOpenDataChannel:(RT
 /** Called any time the PeerConnectionState changes. */
 - (void)peerConnection:(RTCPeerConnection *)peerConnection
 didChangeConnectionState:(RTCPeerConnectionState)newState {
-    
+    FlutterEventSink eventSink = peerConnection.eventSink;
+    if(eventSink){
+        eventSink(@{
+                    @"event" : @"peerConnectionState",
+                    @"state": [self stringForPeerConnectionState:newState]
+                    });
+    }
 }
 
 - (void)peerConnection:(RTCPeerConnection *)peerConnection
 
@@ -70,6 +70,10 @@ class _MyAppState extends State<LoopBackSample> {
     print(state);
   }
 
+  void _onPeerConnectionState(RTCPeerConnectionState state) {
+    print(state);
+  }
+
   void _onAddStream(MediaStream stream) {
     print('New stream: ' + stream.id);
     //_remoteRenderer.srcObject = stream;
@@ -143,6 +147,7 @@ class _MyAppState extends State<LoopBackSample> {
       _peerConnection.onSignalingState = _onSignalingState;
       _peerConnection.onIceGatheringState = _onIceGatheringState;
       _peerConnection.onIceConnectionState = _onIceConnectionState;
+      _peerConnection.onConnectionState = _onPeerConnectionState;
       _peerConnection.onAddStream = _onAddStream;
       _peerConnection.onRemoveStream = _onRemoveStream;
       _peerConnection.onIceCandidate = _onCandidate;