feat: release v1.0.0

Author: codeestX

README.md

@@ -40,25 +40,33 @@ SocketClient mClient = RxSocketClient
 ### connect
 ```java
 Disposable ref = mClient.connect()
-						... // anything else what you can do with RxJava
+			... // anything else what you can do with RxJava
                 .observeOn(AndroidSchedulers.mainThread())
                 .subscribe(new SocketSubscriber() {
                     @Override
                     public void onConnected() {
+                    	//onConnected
                         Log.e(TAG, "onConnected");
                     }
 
                     @Override
                     public void onDisconnected() {
+                    	//onDisconnected
                         Log.e(TAG, "onDisconnected");
                     }
 
                     @Override
                     public void onResponse(@NotNull byte[] data) {
-                    	// receive data
+                    	//receive data
                         Log.e(TAG, Arrays.toString(data));
                     }
-                });
+                }, new Consumer<Throwable>() {
+						   @Override
+						   public void accept(Throwable throwable) throws Exception {
+						      //onError
+						       Log.e(TAG, throwable.toString());
+						   }
+					  });
 ```
 
 ### disconnect

RxSocketClient/build.gradle

@@ -1,6 +1,11 @@
 apply plugin: 'java-library'
 apply plugin: 'kotlin'
 
+// JitPack Maven
+apply plugin: 'com.github.dcendents.android-maven'
+// Group
+group='com.github.codeestX'
+
 dependencies {
     implementation fileTree(dir: 'libs', include: ['*.jar'])
     compile "org.jetbrains.kotlin:kotlin-stdlib-jre8:$kotlin_version"

RxSocketClient/src/main/java/moe/codeest/rxsocketclient/SocketClient.kt

@@ -99,4 +99,8 @@ class SocketClient(val mConfig: SocketConfig) {
     fun sendData(string: String) {
         sendData(string.toByteArray(charset = mConfig.mCharset))
     }
+
+    fun isConnecting(): Boolean {
+        return mSocket.isConnected
+    }
 }

app/src/main/java/moe/codeest/rxsocketclientdemo/JavaActivity.java

@@ -13,6 +13,7 @@
 
 import io.reactivex.android.schedulers.AndroidSchedulers;
 import io.reactivex.disposables.Disposable;
+import io.reactivex.functions.Consumer;
 import kotlin.text.Charsets;
 import moe.codeest.rxsocketclient.RxSocketClient;
 import moe.codeest.rxsocketclient.SocketClient;
@@ -81,21 +82,30 @@ private void connect() {
                 .subscribe(new SocketSubscriber() {
                     @Override
                     public void onConnected() {
+                        //onConnected
                         Log.e(TAG, "onConnected");
                     }
 
                     @Override
                     public void onDisconnected() {
+                        //onDisconnected
                         Log.e(TAG, "onDisconnected");
                         //re-connect
 //                        connect();
                     }
 
                     @Override
                     public void onResponse(@NotNull byte[] data) {
+                        //receive data
                         Log.e(TAG, Arrays.toString(data));
                         tvReceive.setText(Arrays.toString(data));
                     }
+                }, new Consumer<Throwable>() {
+                    @Override
+                    public void accept(Throwable throwable) throws Exception {
+                        //onError
+                        Log.e(TAG, throwable.toString());
+                    }
                 });
     }
 

build.gradle

@@ -9,6 +9,7 @@ buildscript {
     dependencies {
         classpath 'com.android.tools.build:gradle:3.0.0-alpha4'
         classpath "org.jetbrains.kotlin:kotlin-gradle-plugin:$kotlin_version"
+        classpath 'com.github.dcendents:android-maven-gradle-plugin:1.5'
 
         // NOTE: Do not place your application dependencies here; they belong
         // in the individual module build.gradle files