diff --git a/rxjava-2/pom.xml b/rxjava-2/pom.xml
index f437a6005b..3038c20037 100644
--- a/rxjava-2/pom.xml
+++ b/rxjava-2/pom.xml
@@ -1,53 +1,53 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
-    <modelVersion>4.0.0</modelVersion>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
 
-    <artifactId>rxjava-2</artifactId>
-    <version>1.0-SNAPSHOT</version>
+	<artifactId>rxjava-2</artifactId>
+	<version>1.0-SNAPSHOT</version>
 
-    <parent>
-        <groupId>com.baeldung</groupId>
-        <artifactId>parent-java</artifactId>
-        <version>0.0.1-SNAPSHOT</version>
-        <relativePath>../parent-java</relativePath>
-    </parent>
+	<parent>
+		<groupId>com.baeldung</groupId>
+		<artifactId>parent-java</artifactId>
+		<version>0.0.1-SNAPSHOT</version>
+		<relativePath>../parent-java</relativePath>
+	</parent>
 
-    <dependencies>
-        <dependency>
-            <groupId>io.reactivex.rxjava2</groupId>
-            <artifactId>rxjava</artifactId>
-            <version>${rx.java2.version}</version>
-        </dependency>
-        <dependency>
-            <groupId>com.jayway.awaitility</groupId>
-            <artifactId>awaitility</artifactId>
-            <version>${awaitility.version}</version>
-        </dependency>
-        <dependency>
-            <groupId>org.assertj</groupId>
-            <artifactId>assertj-core</artifactId>
-            <version>${assertj.version}</version>
-        </dependency>
-        <dependency>
-            <groupId>com.jakewharton.rxrelay2</groupId>
-            <artifactId>rxrelay</artifactId>
-            <version>${rxrelay.version}</version>
-        </dependency>
-        <!-- https://mvnrepository.com/artifact/com.github.akarnokd/rxjava2-extensions -->
-<dependency>
-    <groupId>com.github.akarnokd</groupId>
-    <artifactId>rxjava2-extensions</artifactId>
-    <version>${rxjava2.ext.version}</version>
-</dependency>
-        
-    </dependencies>
+	<dependencies>
+		<dependency>
+			<groupId>io.reactivex.rxjava2</groupId>
+			<artifactId>rxjava</artifactId>
+			<version>${rx.java2.version}</version>
+		</dependency>
+		<dependency>
+			<groupId>com.jayway.awaitility</groupId>
+			<artifactId>awaitility</artifactId>
+			<version>${awaitility.version}</version>
+		</dependency>
+		<dependency>
+			<groupId>org.assertj</groupId>
+			<artifactId>assertj-core</artifactId>
+			<version>${assertj.version}</version>
+		</dependency>
+		<dependency>
+			<groupId>com.jakewharton.rxrelay2</groupId>
+			<artifactId>rxrelay</artifactId>
+			<version>${rxrelay.version}</version>
+		</dependency>
+		<!-- https://mvnrepository.com/artifact/com.github.akarnokd/rxjava2-extensions -->
+		<dependency>
+			<groupId>com.github.akarnokd</groupId>
+			<artifactId>rxjava2-extensions</artifactId>
+			<version>${rxjava2.ext.version}</version>
+		</dependency>
+	</dependencies>
 
-    <properties>
-        <assertj.version>3.8.0</assertj.version>
-        <rx.java2.version>2.2.2</rx.java2.version>
-        <awaitility.version>1.7.0</awaitility.version>
-        <rxrelay.version>2.0.0</rxrelay.version>
-        <rxjava2.ext.version>0.20.4</rxjava2.ext.version>
-    </properties>
+	<properties>
+		<assertj.version>3.8.0</assertj.version>
+		<rx.java2.version>2.2.2</rx.java2.version>
+		<awaitility.version>1.7.0</awaitility.version>
+		<rxrelay.version>2.0.0</rxrelay.version>
+		<rxjava2.ext.version>0.20.4</rxjava2.ext.version>
+	</properties>
 </project>
\ No newline at end of file
diff --git a/rxjava-2/src/test/java/com/baeldung/rxjava/AsyncAndSyncToObservableIntegrationTest.java b/rxjava-2/src/test/java/com/baeldung/rxjava/AsyncAndSyncToObservableIntegrationTest.java
index a646b453ff..90f4fe94ae 100644
--- a/rxjava-2/src/test/java/com/baeldung/rxjava/AsyncAndSyncToObservableIntegrationTest.java
+++ b/rxjava-2/src/test/java/com/baeldung/rxjava/AsyncAndSyncToObservableIntegrationTest.java
@@ -21,8 +21,9 @@ public class AsyncAndSyncToObservableIntegrationTest {
     AtomicInteger counter = new AtomicInteger();
     Callable<Integer> callable = () -> counter.incrementAndGet();
 
+    /* Method will execute every time it gets subscribed*/
     @Test
-    public void givenSyncMethod_whenConvertedWithFromCallable_thenReturnObservable() {// method will execute every time it gets subscribed
+    public void givenSyncMethod_whenConvertedWithFromCallable_thenReturnObservable() {
 
         Observable<Integer> source = Observable.fromCallable(callable);
 
@@ -35,8 +36,9 @@ public class AsyncAndSyncToObservableIntegrationTest {
         }
     }
 
+    /* Method will execute only once and cache its result.*/
     @Test
-    public void givenSyncMethod_whenConvertedWithStart_thenReturnObservable() {// method will execute only once and cache its result.
+    public void givenSyncMethod_whenConvertedWithStart_thenReturnObservable() {
 
         Observable<Integer> source = AsyncObservable.start(callable);
 
@@ -49,8 +51,9 @@ public class AsyncAndSyncToObservableIntegrationTest {
         }
     }
 
+    /* Method will execute only once and cache its result.*/
     @Test
-    public void givenAsyncMethod_whenConvertedWithFromFuture_thenRetrunObservble() { // method will execute only once and cache its result.
+    public void givenAsyncMethod_whenConvertedWithFromFuture_thenRetrunObservble() { 
 
         ExecutorService executor = Executors.newSingleThreadExecutor();
         Future<Integer> future = executor.submit(callable);
@@ -67,8 +70,9 @@ public class AsyncAndSyncToObservableIntegrationTest {
         executor.shutdown();
     }
 
+    /* Method will execute every time it gets subscribed*/
     @Test
-    public void givenAsyncMethod_whenConvertedWithStartFuture_thenRetrunObservble() {// method will execute every time it gets subscribed
+    public void givenAsyncMethod_whenConvertedWithStartFuture_thenRetrunObservble() {
 
         ExecutorService executor = Executors.newSingleThreadExecutor();
         Observable<Integer> source = AsyncObservable.startFuture(() -> executor.submit(callable));
@@ -84,9 +88,9 @@ public class AsyncAndSyncToObservableIntegrationTest {
         executor.shutdown();
     }
 
+    /*Method will execute only once and cache its result.*/
     @Test
-    public void givenAsyncMethod_whenConvertedWithDeferFuture_thenRetrunObservble() { // method will execute only once and cache its result.
-
+    public void givenAsyncMethod_whenConvertedWithDeferFuture_thenRetrunObservble() { 
         List<Integer> list = Arrays.asList(new Integer[] { counter.incrementAndGet(), counter.incrementAndGet(), counter.incrementAndGet() });
         ExecutorService exec = Executors.newSingleThreadExecutor();
         Callable<Observable<Integer>> callable = () -> Observable.fromIterable(list);