Add test for DirectRTCClient in AppRTC Demo for Android

webrtc/examples/androidapp/src/org/appspot/apprtc/DirectRTCClient.java

 /*
  *  Copyright 2016 The WebRTC Project Authors. All rights reserved.
  *
  *  Use of this source code is governed by a BSD-style license
  *  that can be found in the LICENSE file in the root of the source
  *  tree. An additional intellectual property rights grant can be found
  *  in the file PATENTS.  All contributing project authors may
  *  be found in the AUTHORS file in the root of the source tree.
  */
 
@@ skipping 46 matching lines @@
   private TCPChannelClient tcpClient;
   private RoomConnectionParameters connectionParameters;
 
   private enum ConnectionState {
     NEW, CONNECTED, CLOSED, ERROR
   };
 
   // All alterations of the room state should be done from inside the looper thread.
   private ConnectionState roomState;
 
-  public DirectRTCClient(SignalingEvents events) {
+  public DirectRTCClient(SignalingEvents events, LooperExecutor looperExecutor) {
     this.events = events;
-    executor = new LooperExecutor();
+    executor = looperExecutor;
 
     executor.requestStart();
     roomState = ConnectionState.NEW;
   }
 
   /**
    * Connects to the room, roomId in connectionsParameters is required. roomId must be a valid
    * IP address matching IP_PATTERN.
    */
   @Override
@@ skipping 13 matching lines @@
   }
 
   @Override
   public void disconnectFromRoom() {
     executor.execute(new Runnable() {
       @Override
       public void run() {
         disconnectFromRoomInternal();
       }
     });
-    executor.requestStop();
   }
 
   /**
    * Connects to the room.
    *
    * Runs on the looper thread.
    */
   private void connectToRoomInternal() {
     this.roomState = ConnectionState.NEW;
 
@@ skipping 175 matching lines @@
         reportError("Unexpected TCP message: " + msg);
       }
     } catch (JSONException e) {
       reportError("TCP message JSON parsing error: " + e.toString());
     }
   }
 
   @Override
   public void onTCPError(String description) {
     reportError("TCP connection error: " + description);
+    executor.requestStop();
   }
 
   @Override
   public void onTCPClose() {
     events.onChannelClose();
+    executor.requestStop();
   }
 
   // --------------------------------------------------------------------
   // Helper functions.
   private void reportError(final String errorMessage) {
     Log.e(TAG, errorMessage);
     executor.execute(new Runnable() {
       @Override
       public void run() {
         if (roomState != ConnectionState.ERROR) {
@@ skipping 31 matching lines @@
     return json;
   }
 
   // Converts a JSON candidate to a Java object.
   private static IceCandidate toJavaCandidate(JSONObject json) throws JSONException {
     return new IceCandidate(json.getString("id"),
         json.getInt("label"),
         json.getString("candidate"));
   }
 }