test env and eventbus fixes

android/app/build.gradle

@@ -1,3 +1,12 @@
+buildscript {
+    repositories {
+        jcenter()
+    }
+    dependencies {
+        classpath 'com.android.tools.build:gradle:2.1.3'
+    }
+}
+
 apply plugin: 'com.android.library'
 
 android {
@@ -30,9 +39,11 @@ android {
 }
 
 repositories {
+    mavenLocal()
+    jcenter()
     maven {
         // All of React Native (JS, Obj-C sources, Android binaries) is installed from npm
-        url '../../../react-native/android'
+        url "$rootDir/../../example-redux/node_modules/react-native/android"
     }
 }
 
@@ -54,4 +65,10 @@ dependencies {
 
     testCompile "junit:junit:4.12"
     testCompile "org.robolectric:robolectric:3.1.1"
+    testCompile 'org.assertj:assertj-core:3.5.2'
+}
+
+task unit(dependsOn: 'testLibraryDebugUnitTest') << {
+    println 'Finished running unit all tests'
+    println 'report at file://' + tasks.testLibraryDebugUnitTest.outputs.files.last().absolutePath + '/index.html'
 }

android/app/src/main/java/com/reactnativenavigation/events/EventBus.java

@@ -1,31 +1,44 @@
 package com.reactnativenavigation.events;
 
+import java.lang.ref.WeakReference;
 import java.util.ArrayList;
 import java.util.List;
 
 public enum EventBus {
     instance;
 
-    List<Subscriber> subscribers;
-
-    EventBus() {
-        subscribers = new ArrayList<>();
-    }
+    private final List<WeakReference<Subscriber>> subscribers = new ArrayList<>();
 
     public void register(Subscriber subscriber) {
-        if (subscribers.contains(subscriber)) {
-            throw new RuntimeException("Subscriber already registered");
-        }
-        subscribers.add(subscriber);
+        if (isSubscribed(subscriber)) return;
+        subscribers.add(new WeakReference<>(subscriber));
     }
 
     public void unregister(Subscriber subscriber) {
-        subscribers.remove(subscriber);
+        for (WeakReference<Subscriber> ref : subscribers) {
+            Subscriber registered = ref.get();
+            if (registered != null && registered == subscriber) {
+                subscribers.remove(ref);
+            }
+        }
     }
 
     public void post(Event event) {
-        for (Subscriber subscriber : subscribers) {
-            subscriber.onEvent(event);
+        for (WeakReference<Subscriber> ref : subscribers) {
+            Subscriber registered = ref.get();
+            if (registered != null) {
+                registered.onEvent(event);
+            }
+        }
+    }
+
+    public boolean isSubscribed(Subscriber subscriber) {
+        for (WeakReference<Subscriber> ref : subscribers) {
+            Subscriber registered = ref.get();
+            if (registered != null && registered.equals(subscriber)) {
+                return true;
+            }
         }
+        return false;
     }
 }

android/app/src/test/java/com/reactnativenavigation/EnvironmentTest.java

@@ -0,0 +1,15 @@
+package com.reactnativenavigation;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.robolectric.RobolectricTestRunner;
+
+import static org.assertj.core.api.Java6Assertions.assertThat;
+
+@RunWith(RobolectricTestRunner.class)
+public class EnvironmentTest {
+    @Test
+    public void assertJ() {
+        assertThat(1 + 2).isEqualTo(3);
+    }
+}

android/app/src/test/java/com/reactnativenavigation/FirstTest.java

@@ -1,17 +0,0 @@
-package com.reactnativenavigation;
-
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.robolectric.RobolectricTestRunner;
-
-import static org.hamcrest.Matchers.is;
-import static org.junit.Assert.assertThat;
-
-//TODO test the shit out of this project
-@RunWith(RobolectricTestRunner.class)
-public class FirstTest {
-    @Test
-    public void woohoo() {
-        assertThat(1 + 2, is(3));
-    }
-}

example-redux/android/app/build.gradle

@@ -115,7 +115,7 @@ android {
         variant.outputs.each { output ->
             // For each separate APK per architecture, set a unique version code as described here:
             // http://tools.android.com/tech-docs/new-build-system/user-guide/apk-splits
-            def versionCodes = ["armeabi-v7a":1, "x86":2]
+            def versionCodes = ["armeabi-v7a": 1, "x86": 2]
             def abi = output.getFilter(OutputFile.ABI)
             if (abi != null) {  // null for the universal-debug, universal-release variants
                 output.versionCodeOverride =
@@ -136,6 +136,6 @@ dependencies {
 // Run this once to be able to run the application with BUCK
 // puts all compile dependencies into folder libs for BUCK to use
 task copyDownloadableDepsToLibs(type: Copy) {
-  from configurations.compile
-  into 'libs'
+    from configurations.compile
+    into 'libs'
 }