add alias limit for Stream.take

davidmoten · Feb 10, 2024 · e4b292e · e4b292e
1 parent 5f1641f
commit e4b292e
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/kool/src/main/java/org/davidmoten/kool/Stream.java b/kool/src/main/java/org/davidmoten/kool/Stream.java
@@ -764,6 +764,10 @@ default Maybe<T> get(long index) {
     default Stream<T> take(long n) {
         return new Take<T>(n, this);
     }
+
+    default Stream<T> limit(long n) {
+        return take(n);
+    }
 
     default Stream<T> takeLast(long n) {
         return new TakeLast<T>(this, n);

diff --git a/kool/src/test/java/org/davidmoten/kool/StreamTest.java b/kool/src/test/java/org/davidmoten/kool/StreamTest.java
@@ -1202,7 +1202,7 @@ public void testGenerateInfiniteValues() {
             i.incrementAndGet();
             emitter.onNext(i.get());
         }) //
-                .take(5) //
+                .limit(5) //
                 .test() //
                 .assertValuesOnly(1, 2, 3, 4, 5);