Include required dependencies.

Update to RxJava2 RC4.
Add getObservable method to Callbacks class.

Change-Id: I4cb68413118a28e6f7103c4f7919c178ea80e676

Author: Randy Webster

README.md

@@ -1,7 +1,7 @@
 #RxLoader
 [![License](http://img.shields.io/badge/License-Apache%202.0-blue.svg?style=flat-square)](http://www.apache.org/licenses/LICENSE-2.0)
 [![API](https://img.shields.io/badge/API-16%2B-blue.svg?style=flat-square)](https://developer.android.com/about/versions/android-4.1.html)
-[![Download](https://img.shields.io/badge/JCenter-2.0.0--RC1-brightgreen.svg?style=flat-square)](https://bintray.com/l4digital/maven/RxLoader/_latestVersion)
+[![Download](https://img.shields.io/badge/JCenter-2.0.0--RC2-brightgreen.svg?style=flat-square)](https://bintray.com/l4digital/maven/RxLoader/_latestVersion)
 
 An Android Loader that wraps an RxJava Observable.
 
@@ -14,7 +14,7 @@ RxLoader caches the data emitted by your Observable across orientation changes b
 ####Gradle:
 ~~~groovy
 dependencies {
-    compile 'com.l4digital.rxloader:rxloader:2.0.0-RC1'
+    compile 'com.l4digital.rxloader:rxloader:2.0.0-RC2'
 }
 ~~~
 
@@ -23,7 +23,7 @@ dependencies {
 <dependency>
   <groupId>com.l4digital.rxloader</groupId>
   <artifactId>rxloader</artifactId>
-  <version>2.0.0-RC1</version>
+  <version>2.0.0-RC2</version>
 </dependency>
 ~~~
 

rxloader/build.gradle

@@ -21,7 +21,7 @@ apply plugin: 'maven-publish'
 def libraryName = 'RxLoader'
 def libraryArtifact = 'rxloader'
 def libraryGroup = 'com.l4digital.rxloader'
-def libraryVersion = '2.0.0-RC1'
+def libraryVersion = '2.0.0-RC2'
 
 android {
     compileSdkVersion 24
@@ -39,7 +39,7 @@ android {
 }
 
 dependencies {
-    compile 'io.reactivex.rxjava2:rxjava:2.0.0-RC3'
+    compile 'io.reactivex.rxjava2:rxjava:2.0.0-RC4'
     compile 'io.reactivex.rxjava2:rxandroid:2.0.0-RC1'
 }
 
@@ -70,7 +70,29 @@ publishing {
             artifact("$buildDir/outputs/aar/${artifactId}-release.aar")
 
             pom.withXml {
-                // ignore dependencies to force consumers to specify version
+                def dependencies = asNode().appendNode('dependencies')
+
+                configurations.getByName("_releaseCompile").allDependencies.each {
+                    def dependency = dependencies.appendNode('dependency')
+
+                    dependency.appendNode('groupId', it.group)
+                    dependency.appendNode('artifactId', it.name)
+                    dependency.appendNode('version', it.version)
+
+                    if (it.excludeRules.size() > 0) {
+                        def exclusions = dependency.appendNode('exclusions')
+
+                        it.excludeRules.each { ExcludeRule rule ->
+                            def exclusion = exclusions.appendNode('exclusion')
+
+                            exclusion.appendNode('groupId', rule.group)
+
+                            if (rule.module != null) {
+                                exclusion.appendNode('artifactId', rule.module)
+                            }
+                        }
+                    }
+                }
             }
         }
 
@@ -99,6 +121,7 @@ bintray {
 
         version {
             name = libraryVersion
+            vcsTag = libraryVersion
             released = new Date()
         }
     }

rxloader/src/main/java/com/l4digital/rxloader/RxLoader.java

@@ -119,7 +119,7 @@ private void dispose() {
         }
     }
 
-    private DisposableSubscriber<T> createSubscriber() {
+    private synchronized DisposableSubscriber<T> createSubscriber() {
         if (mSubscriber == null || mSubscriber.isDisposed()) {
             mSubscriber = new DisposableSubscriber<T>() {
 

rxloader/src/main/java/com/l4digital/rxloader/RxLoaderCallbacks.java

@@ -21,6 +21,7 @@
 import android.os.Bundle;
 
 import io.reactivex.Flowable;
+import io.reactivex.Observable;
 import io.reactivex.processors.BehaviorProcessor;
 
 public class RxLoaderCallbacks<T> implements LoaderManager.LoaderCallbacks<T> {
@@ -32,6 +33,10 @@ public Flowable<T> getFlowable() {
         return createProcessor();
     }
 
+    public Observable<T> getObservable() {
+        return createProcessor().toObservable();
+    }
+
     public RxLoaderCallbacks(RxLoader<T> loader) {
         mLoader = loader;
     }
@@ -67,7 +72,7 @@ public void onLoaderReset(Loader<T> loader) {
         mProcessor.onComplete();
     }
 
-    private BehaviorProcessor<T> createProcessor() {
+    private synchronized BehaviorProcessor<T> createProcessor() {
         if (mProcessor == null || mProcessor.hasComplete()) {
             mProcessor = BehaviorProcessor.create();
         }