Use lambdas and method references (Java 8 or Android Plugin 3.x).

Author: greenrobot-team

objectbox-java/src/main/java/io/objectbox/BoxStore.java

@@ -278,13 +278,10 @@ static boolean isFileOpen(final String canonicalPath) {
         }
         if (openFilesCheckerThread == null || !openFilesCheckerThread.isAlive()) {
             // Use a thread to avoid finalizers that block us
-            openFilesCheckerThread = new Thread() {
-                @Override
-                public void run() {
-                    isFileOpenSync(canonicalPath, true);
-                    openFilesCheckerThread = null; // Clean ref to itself
-                }
-            };
+            openFilesCheckerThread = new Thread(() -> {
+                isFileOpenSync(canonicalPath, true);
+                openFilesCheckerThread = null; // Clean ref to itself
+            });
             openFilesCheckerThread.setDaemon(true);
             openFilesCheckerThread.start();
             try {
@@ -834,18 +831,15 @@ public <R> R callInTxNoException(Callable<R> callable) {
      * See also {@link #runInTx(Runnable)}.
      */
     public void runInTxAsync(final Runnable runnable, @Nullable final TxCallback<Void> callback) {
-        threadPool.submit(new Runnable() {
-            @Override
-            public void run() {
-                try {
-                    runInTx(runnable);
-                    if (callback != null) {
-                        callback.txFinished(null, null);
-                    }
-                } catch (Throwable failure) {
-                    if (callback != null) {
-                        callback.txFinished(null, failure);
-                    }
+        threadPool.submit(() -> {
+            try {
+                runInTx(runnable);
+                if (callback != null) {
+                    callback.txFinished(null, null);
+                }
+            } catch (Throwable failure) {
+                if (callback != null) {
+                    callback.txFinished(null, failure);
                 }
             }
         });
@@ -858,18 +852,15 @@ public void run() {
      * * See also {@link #callInTx(Callable)}.
      */
     public <R> void callInTxAsync(final Callable<R> callable, @Nullable final TxCallback<R> callback) {
-        threadPool.submit(new Runnable() {
-            @Override
-            public void run() {
-                try {
-                    R result = callInTx(callable);
-                    if (callback != null) {
-                        callback.txFinished(result, null);
-                    }
-                } catch (Throwable failure) {
-                    if (callback != null) {
-                        callback.txFinished(null, failure);
-                    }
+        threadPool.submit(() -> {
+            try {
+                R result = callInTx(callable);
+                if (callback != null) {
+                    callback.txFinished(result, null);
+                }
+            } catch (Throwable failure) {
+                if (callback != null) {
+                    callback.txFinished(null, failure);
                 }
             }
         });

objectbox-java/src/main/java/io/objectbox/BoxStoreBuilder.java

@@ -22,11 +22,9 @@
 import java.io.BufferedOutputStream;
 import java.io.File;
 import java.io.FileInputStream;
-import java.io.FileNotFoundException;
 import java.io.FileOutputStream;
 import java.io.InputStream;
 import java.io.OutputStream;
-import java.lang.reflect.InvocationTargetException;
 import java.lang.reflect.Method;
 import java.util.ArrayList;
 import java.util.List;
@@ -353,12 +351,7 @@ public BoxStoreBuilder failedReadTxAttemptCallback(TxCallback failedReadTxAttemp
      */
     @Experimental
     public BoxStoreBuilder initialDbFile(final File initialDbFile) {
-        return initialDbFile(new Factory<InputStream>() {
-            @Override
-            public InputStream provide() throws FileNotFoundException {
-                return new FileInputStream(initialDbFile);
-            }
-        });
+        return initialDbFile(() -> new FileInputStream(initialDbFile));
     }
 
     /**

objectbox-java/src/main/java/io/objectbox/ObjectClassPublisher.java

@@ -77,17 +77,14 @@ private void unsubscribe(DataObserver<Class> observer, int entityTypeId) {
 
     @Override
     public void publishSingle(final DataObserver<Class> observer, @Nullable final Object forClass) {
-        boxStore.internalScheduleThread(new Runnable() {
-            @Override
-            public void run() {
-                Collection<Class> entityClasses = forClass != null ? Collections.singletonList((Class) forClass) :
-                        boxStore.getAllEntityClasses();
-                for (Class entityClass : entityClasses) {
-                    try {
-                        observer.onData(entityClass);
-                    } catch (RuntimeException e) {
-                        handleObserverException(entityClass);
-                    }
+        boxStore.internalScheduleThread(() -> {
+            Collection<Class> entityClasses = forClass != null ? Collections.singletonList((Class) forClass) :
+                    boxStore.getAllEntityClasses();
+            for (Class entityClass : entityClasses) {
+                try {
+                    observer.onData(entityClass);
+                } catch (RuntimeException e) {
+                    handleObserverException(entityClass);
                 }
             }
         });

objectbox-java/src/main/java/io/objectbox/query/LazyList.java

@@ -136,12 +136,10 @@ public void loadRemaining() {
         if (loadedCount != size) {
             checkCached();
             // use single reader only for efficiency
-            box.getStore().runInReadTx(new Runnable() {
-                @Override
-                public void run() {
-                    for (int i = 0; i < size; i++) {
-                        get(i);
-                    }
+            box.getStore().runInReadTx(() -> {
+                for (int i = 0; i < size; i++) {
+                    //noinspection ResultOfMethodCallIgnored
+                    get(i);
                 }
             });
         }