Skip to content
This repository was archived by the owner on Mar 2, 2022. It is now read-only.

Commit 92b8200

Browse files
committed
Remove erasure warning
Upgrade gradle to 4.4
1 parent 88dbcba commit 92b8200

File tree

2 files changed

+4
-5
lines changed

2 files changed

+4
-5
lines changed
Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
1-
distributionUrl=https\://services.gradle.org/distributions/gradle-4.4-bin.zip
1+
#Mon Dec 11 07:53:02 SGT 2017
22
distributionBase=GRADLE_USER_HOME
33
distributionPath=wrapper/dists
4-
zipStorePath=wrapper/dists
54
zipStoreBase=GRADLE_USER_HOME
5+
zipStorePath=wrapper/dists
6+
distributionUrl=https\://services.gradle.org/distributions/gradle-4.4-all.zip

src/main/scala/reactor/core/scala/publisher/Flux.scala

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1786,9 +1786,7 @@ class Flux[T] private[publisher](private[publisher] val jFlux: JFlux[T]) extends
17861786
*
17871787
* @return an indexed [[Flux]] with each source value combined with its 0-based index.
17881788
*/
1789-
final def index(): Flux[(Long, T)] = Flux(jFlux.index()).map(tupleTwo2ScalaTuple2) map {
1790-
case (jLong: JLong, t: T) => (Long2long(jLong), t)
1791-
}
1789+
final def index(): Flux[(Long, T)] = Flux(jFlux.index()).map(t2 => (Long2long(t2.getT1), t2.getT2))
17921790

17931791
/**
17941792
* Keep information about the order in which source values were received by

0 commit comments

Comments
 (0)