Further clean up

README.md

@@ -15,17 +15,19 @@ Dependencies
 ------------
 The library is available on JCenter. The latest version is 2.1.0.
 
+Replace ``{LATEST-VERSION}`` with the latest version.
+
 **Gradle setup**
 ```gradle
-implementation 'uk.co.hassie.libraries:async-threader:<LATEST-VERSION>'
+implementation 'uk.co.hassie.libraries:async-threader:{LATEST-VERSION}'
 ```
 
 **Maven setup**
 ```maven
 <dependency>
   <groupId>uk.co.hassie.libraries</groupId>
   <artifactId>async-threader</artifactId>
-  <version><LATEST-VERSION></version>
+  <version>{LATEST-VERSION}</version>
   <type>pom</type>
 </dependency>
 ```

library/build.gradle

@@ -15,7 +15,7 @@
  */
 
 group = 'uk.co.hassie.libraries'
-version = '2.1.0'
+version = '2.2.0'
 
 apply plugin: 'java'
 apply plugin: 'com.novoda.bintray-release'
@@ -35,7 +35,7 @@ publish {
     userOrg = 'hassieswift621'
     groupId = 'uk.co.hassie.libraries'
     artifactId = 'async-threader'
-    publishVersion = '2.1.0'
+    publishVersion = '2.2.0'
     desc = 'A type-safe Java async threader which automatically executes callbacks after a callable or future completes or fails.'
     website = 'https://github.com/hassieswift621/async-threader'
 }

library/src/main/java/uk/co/hassie/libraries/asyncthreader/AsyncThreader.java

@@ -23,7 +23,7 @@
 
 public class AsyncThreader {
 
-    private ExecutorService mExecutorService;
+    private ExecutorService executorService;
 
     public static class Builder {
 
@@ -60,7 +60,7 @@ public AsyncThreader build() {
      * Creates the async threader instance with default options.
      */
     public AsyncThreader() {
-        mExecutorService = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors() + 1);
+        executorService = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors() + 1);
     }
 
     /**
@@ -69,7 +69,7 @@ public AsyncThreader() {
      * @param threadPoolSize The thread pool size.
      */
     private AsyncThreader(int threadPoolSize) {
-        mExecutorService = Executors.newFixedThreadPool(threadPoolSize);
+        executorService = Executors.newFixedThreadPool(threadPoolSize);
     }
 
 
@@ -79,7 +79,7 @@ private AsyncThreader(int threadPoolSize) {
      * @param request The request to execute.
      */
     public <T> void execute(Request<T> request) {
-        mExecutorService.submit(request);
+        executorService.submit(request);
     }
 
     /**
@@ -101,7 +101,7 @@ public <T> CompletableFuture<T> execute(Callable<T> callable) {
         );
 
         // Execute request.
-        mExecutorService.submit(request);
+        executorService.submit(request);
 
         return future;
     }
@@ -113,14 +113,14 @@ public <T> CompletableFuture<T> execute(Callable<T> callable) {
      */
     public void execute(Runnable runnable) {
         // Execute request.
-        mExecutorService.submit(runnable);
+        executorService.submit(runnable);
     }
 
     /**
      * Shutdown the async threader's executor service.
      */
     public void shutdown() {
-        mExecutorService.shutdown();
+        executorService.shutdown();
     }
 
 }

library/src/main/java/uk/co/hassie/libraries/asyncthreader/Request.java

@@ -22,8 +22,8 @@
 
 public class Request<T> extends FutureTask<T> {
 
-    private final Response<T> mResponse;
-    private final Error mError;
+    private final Response<T> response;
+    private final Error error;
 
     /**
      * Create a request.
@@ -34,21 +34,22 @@ public class Request<T> extends FutureTask<T> {
      */
     public Request(Callable<T> callable, Response<T> response, Error error) {
         super(callable);
-        mResponse = response;
-        mError = error;
+        this.response = response;
+        this.error = error;
     }
 
     /**
-     * Run the callback after the task is completed.
+     * Executes the callbacks after task has completed.
      */
     @Override
     protected void done() {
         try {
-            mResponse.onResponse(this.get());
+            this.response.onResponse(this.get());
         } catch (InterruptedException e) {
-            mError.onError(e);
+            this.error.onError(e);
         } catch (ExecutionException e) {
-            mError.onError(e.getCause());
+            this.error.onError(e.getCause());
         }
     }
+
 }

sample/build.gradle

@@ -15,7 +15,7 @@
  */
 
 group = 'uk.co.hassie.libraries'
-version = '2.1.0'
+version = '2.2.0'
 
 apply plugin: 'java'