We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6afc247 commit 2a85c91Copy full SHA for 2a85c91
build.gradle
@@ -78,7 +78,7 @@ class FixRestChannel {
78
79
final Comparator<T> comparator = comparingInstant(keyExtractor);
80
final AtomicLong previousStart = new AtomicLong(startAt.getEpochSecond());
81
- final AtomicInteger previousStart_ns = new AtomicLong(startAt.getNano());
+ final AtomicInteger previousStart_ns = new AtomicInteger(startAt.getNano());
82
83
return Flux.defer { nextPage.apply(previousStart.get(), previousStart_ns.get()) }
84
.sort(reverse ? comparator.reversed() : comparator)
0 commit comments