Update ReplaySubjectPerf.java

achinthagunasekara · achinthagunasekara · commit efec486d36c3 · 2015-12-18T11:40:22.000+11:00
diff --git a/src/perf/java/rx/subjects/ReplaySubjectPerf.java b/src/perf/java/rx/subjects/ReplaySubjectPerf.java
@@ -70,9 +70,11 @@ public void onNext(Object o) {
                 sum.incrementAndGet();
             }
         });
+        
         for (int i = 0; i < input.nextRuns; i++) {
             subject.onNext("Response");
         }
+        
         subject.onCompleted();
         latch.await();
         bh.consume(sum);
@@ -95,6 +97,7 @@ private void subscribeAfterEvents(ReplaySubject<Object> subject, final Input inp
         for (int i = 0; i < input.nextRuns; i++) {
             subject.onNext("Response");
         }
+        
         subject.onCompleted();
 
         subject.subscribe(new Observer<Object>() {

Original file line number	Diff line number	Diff line change
`@@ -70,9 +70,11 @@ public void onNext(Object o) {`
`70`	`70`	`sum.incrementAndGet();`
`71`	`71`	`}`
`72`	`72`	`});`
	`73`	`+`
`73`	`74`	`for (int i = 0; i < input.nextRuns; i++) {`
`74`	`75`	`subject.onNext("Response");`
`75`	`76`	`}`
	`77`	`+`
`76`	`78`	`subject.onCompleted();`
`77`	`79`	`latch.await();`
`78`	`80`	`bh.consume(sum);`
`@@ -95,6 +97,7 @@ private void subscribeAfterEvents(ReplaySubject<Object> subject, final Input inp`
`95`	`97`	`for (int i = 0; i < input.nextRuns; i++) {`
`96`	`98`	`subject.onNext("Response");`
`97`	`99`	`}`
	`100`	`+`
`98`	`101`	`subject.onCompleted();`
`99`	`102`
`100`	`103`	`subject.subscribe(new Observer<Object>() {`