Merge pull request #942 from aol/fixReactorUpgrade

johnmcclean · web-flow · commit 0d33b6e58d36 · 2018-11-10T15:29:45.000Z
fix repeat / cycle mismatch
diff --git a/cyclops-reactor-integration/src/main/java/com/oath/cyclops/reactor/adapter/FluxReactiveSeqImpl.java b/cyclops-reactor-integration/src/main/java/com/oath/cyclops/reactor/adapter/FluxReactiveSeqImpl.java
@@ -662,7 +662,7 @@ public ReactiveSeq<T> prependAll(Iterable<? extends T> other) {
 
     @Override
     public ReactiveSeq<T> cycle(long times) {
-        return flux(flux.repeat(times));
+        return flux(flux.repeat(times-1));
     }
 
     @Override

Original file line number	Diff line number	Diff line change
`@@ -662,7 +662,7 @@ public ReactiveSeq<T> prependAll(Iterable<? extends T> other) {`
`662`	`662`
`663`	`663`	`@Override`
`664`	`664`	`public ReactiveSeq<T> cycle(long times) {`
`665`		`- return flux(flux.repeat(times));`
	`665`	`+ return flux(flux.repeat(times-1));`
`666`	`666`	`}`
`667`	`667`
`668`	`668`	`@Override`