Streaming from phone. Crashes when starts recording while streaming from phone

Author: fes7713

Android/Layout_Version/app/src/main/java/com/example/layout_version/SenderStream/LiveStreamActivity.java

@@ -18,22 +18,25 @@
 import com.amazonaws.ivs.broadcast.ImagePreviewView;
 import com.amazonaws.ivs.broadcast.Presets;
 import com.amazonaws.ivs.player.PlayerView;
+import com.example.layout_version.MainActivity;
 import com.example.layout_version.R;
 
 import android.Manifest;
 import android.view.ViewGroup;
 import android.widget.FrameLayout;
+import android.widget.ImageButton;
 import android.widget.LinearLayout;
 import android.widget.TextView;
 
-public class LiveStreamActivity extends AppCompatActivity {
+public class LiveStreamActivity extends AppCompatActivity implements LivestreamBroadcastListener.LiveStreamInterface {
 
     public static final String INGEST_ENDPOINT = "ingest_endpoint";
     public static final String STREAM_KEY = "stream_key";
     private FrameLayout previewHolder;
     private BroadcastSession.Listener broadcastListener;
     private BroadcastSession broadcastSession;
     private TextView liveStatusTextView;
+    private ImageButton streamRefreshButton;
 
     private String ingestEndpoint;
     private String streamKey;
@@ -44,8 +47,8 @@ protected void onCreate(Bundle savedInstanceState) {
         setContentView(R.layout.activity_live_stream);
 
         liveStatusTextView = findViewById(R.id.liveStatusTextView);
-
-        broadcastListener = new LivestreamBroadcastListener(this, liveStatusTextView);
+        streamRefreshButton = findViewById(R.id.streamRefreshButton);
+        broadcastListener = new LivestreamBroadcastListener(this, liveStatusTextView, this);
 
         Intent intent = getIntent();
         ingestEndpoint = intent.getStringExtra(INGEST_ENDPOINT);
@@ -72,6 +75,11 @@ protected void onCreate(Bundle savedInstanceState) {
         {
             setupBroadcastSession();
         }
+
+        streamRefreshButton.setOnClickListener(v->{
+            stop();
+            setupBroadcastSession();
+        });
     }
 
     public void setupBroadcastSession()
@@ -87,12 +95,11 @@ public void setupBroadcastSession()
         // awaitDeviceChanges will fire on the main thread after all pending devices
         // attachments have been completed
 
-
+        previewHolder = findViewById(R.id.frameLayout);
         broadcastSession.awaitDeviceChanges(() -> {
             for(Device device: broadcastSession.listAttachedDevices()) {
                 // Find the camera we attached earlier
                 if(device.getDescriptor().type == Device.Descriptor.DeviceType.CAMERA) {
-                    previewHolder = findViewById(R.id.frameLayout);
                     ImagePreviewView preview = ((ImageDevice)device).getPreviewView();
                     preview.setLayoutParams(new LinearLayout.LayoutParams(
                             LinearLayout.LayoutParams.MATCH_PARENT,
@@ -102,9 +109,7 @@ public void setupBroadcastSession()
             }
         });
 
-        broadcastSession.start(
-                ingestEndpoint,
-                streamKey);
+        broadcastSession.start(ingestEndpoint, streamKey);
     }
 
     @Override
@@ -129,9 +134,31 @@ protected void onDestroy() {
         if(broadcastSession != null)
         {
             broadcastSession.stop();
-            previewHolder.removeAllViews();
             broadcastSession.release();
+            if(previewHolder != null)
+                previewHolder.removeAllViews();
+
         }
+    }
 
+    @Override
+    public void stop() {
+        if(broadcastSession != null)
+        {
+            broadcastSession.stop();
+
+            if(previewHolder != null)
+                previewHolder.removeAllViews();
+            broadcastSession.release();
+        }
+    }
+
+    @Override
+    public void reconnect() {
+        if(broadcastSession != null)
+        {
+            stop();
+            setupBroadcastSession();
+        }
     }
 }

Android/Layout_Version/app/src/main/java/com/example/layout_version/SenderStream/LivestreamBroadcastListener.java

@@ -1,6 +1,8 @@
 package com.example.layout_version.SenderStream;
 
 import android.content.Context;
+import android.os.Handler;
+import android.os.Looper;
 import android.support.annotation.NonNull;
 import android.util.Log;
 import android.widget.TextView;
@@ -15,10 +17,13 @@ public class LivestreamBroadcastListener extends BroadcastSession.Listener{
     private Context context;
     private TextView liveStatusTextView;
 
-    public LivestreamBroadcastListener(Context context, TextView liveStatusTextView)
+    private LiveStreamInterface liveStreamInterface;
+
+    public LivestreamBroadcastListener(Context context, TextView liveStatusTextView, LiveStreamInterface liveStreamInterface)
     {
         this.context = context;
         this.liveStatusTextView = liveStatusTextView;
+        this.liveStreamInterface = liveStreamInterface;
     }
 
     @Override
@@ -32,6 +37,10 @@ public void onStateChanged(@NonNull BroadcastSession.State state) {
             case DISCONNECTED:
                 liveStatusTextView.setBackground(AppCompatResources.getDrawable(context, R.drawable.offline_icon));
                 liveStatusTextView.setText(R.string.live_disconnected);
+                final Handler handler = new Handler(Looper.getMainLooper());
+//                handler.postDelayed(() -> {
+//                    liveStreamInterface.reconnect();
+//                }, 2000);
                 break;
             case CONNECTING:
                 liveStatusTextView.setBackground(AppCompatResources.getDrawable(context, R.drawable.buffering_icon));
@@ -44,12 +53,20 @@ public void onStateChanged(@NonNull BroadcastSession.State state) {
             case ERROR:
                 liveStatusTextView.setBackground(AppCompatResources.getDrawable(context, R.drawable.offline_icon));
                 liveStatusTextView.setText(R.string.streaming_offline);
+                liveStreamInterface.stop();
                 break;
         }
     }
 
     @Override
     public void onError(@NonNull BroadcastException exception) {
         Log.e("TAG", "Exception: " + exception);
+
+    }
+
+    interface LiveStreamInterface
+    {
+        void stop();
+        void reconnect();
     }
 }