[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[elpa] externals/stream b0c8949 28/36: Implement `seq-mapn' method for s
From: |
Stefan Monnier |
Subject: |
[elpa] externals/stream b0c8949 28/36: Implement `seq-mapn' method for streams |
Date: |
Tue, 1 Dec 2020 17:22:52 -0500 (EST) |
branch: externals/stream
commit b0c894935f2a87c02c947963d3b95c01976644c6
Author: Michael Heerdegen <michael_heerdegen@web.de>
Commit: Michael Heerdegen <michael_heerdegen@web.de>
Implement `seq-mapn' method for streams
* stream/stream.el (seq-mapn): New method.
* stream/tests/stream-tests.el (stream-seq-mapn-test): New test.
And add a `deftest-for-delayed-evaluation'.
---
stream.el | 22 ++++++++++++++++++++++
tests/stream-tests.el | 15 +++++++++++++++
2 files changed, 37 insertions(+)
diff --git a/stream.el b/stream.el
index b412807..3f6bc4b 100644
--- a/stream.el
+++ b/stream.el
@@ -321,6 +321,28 @@ applications of FUNCTION on each element of STREAM in
succession."
(cons (funcall function (stream-first stream))
(seq-map function (stream-rest stream))))))
+(cl-defmethod seq-mapn (function (stream stream) &rest streams)
+ "Map FUNCTION over the STREAMS.
+
+Example: this prints the first ten Fibonacci numbers:
+
+ (letrec ((fibs (stream-cons
+ 1
+ (stream-cons
+ 1
+ (seq-mapn #'+ fibs (stream-rest fibs))))))
+ (seq-do #'print (seq-take fibs 10)))
+
+\(fn FUNCTION STREAMS...)"
+ (if (not (seq-every-p #'streamp streams))
+ (cl-call-next-method)
+ (cl-labels ((do-mapn (f streams)
+ (stream-make
+ (unless (seq-some #'stream-empty-p streams)
+ (cons (apply f (mapcar #'stream-first streams))
+ (do-mapn f (mapcar #'stream-rest
streams)))))))
+ (do-mapn function (cons stream streams)))))
+
(cl-defmethod seq-do (function (stream stream))
"Evaluate FUNCTION for each element of STREAM eagerly, and return nil.
diff --git a/tests/stream-tests.el b/tests/stream-tests.el
index decf3ad..896c729 100644
--- a/tests/stream-tests.el
+++ b/tests/stream-tests.el
@@ -166,6 +166,18 @@
(should (= -1 (stream-first (seq-map #'- (stream-range 1)))))
(should (= -2 (stream-first (stream-rest (seq-map #'- (stream-range 1)))))))
+(ert-deftest stream-seq-mapn-test ()
+ (should (streamp (seq-mapn #'+ (stream (list 1 2 3)) (stream (list 4 5 6)))))
+ (should (not (streamp (seq-mapn #'+ (stream (list 1 2 3)) (stream (list 4 5
6)) (list 7 8 9)))))
+ (should (= 2 (seq-length (seq-mapn #'+ (stream (list 1 2 3)) (stream (list 4
5))))))
+ (should (equal (letrec ((fibs (stream-cons
+ 1
+ (stream-cons
+ 1
+ (seq-mapn #'+ fibs (stream-rest fibs))))))
+ (seq-into (seq-take fibs 10) 'list))
+ '(1 1 2 3 5 8 13 21 34 55))))
+
(ert-deftest stream-seq-do-test ()
(let ((result '()))
(seq-do
@@ -292,6 +304,9 @@
(deftest-for-delayed-evaluation (seq-drop (make-delayed-test-stream) 2))
(deftest-for-delayed-evaluation (seq-take-while #'numberp
(make-delayed-test-stream)))
(deftest-for-delayed-evaluation (seq-map #'identity
(make-delayed-test-stream)))
+(deftest-for-delayed-evaluation (seq-mapn #'cons
+ (make-delayed-test-stream)
+ (make-delayed-test-stream)))
(deftest-for-delayed-evaluation (seq-filter #'cl-evenp
(make-delayed-test-stream)))
(deftest-for-delayed-evaluation (stream-delay (make-delayed-test-stream)))
(deftest-for-delayed-evaluation (seq-copy (make-delayed-test-stream)))
- [elpa] externals/stream c92d3b4 08/36: * packages/stream/stream.el: Update to version 2.0.2., (continued)
- [elpa] externals/stream c92d3b4 08/36: * packages/stream/stream.el: Update to version 2.0.2., Stefan Monnier, 2020/12/01
- [elpa] externals/stream 11f19ab 10/36: Update stream.el to v2.0.5, Stefan Monnier, 2020/12/01
- [elpa] externals/stream 8af657a 12/36: * packages/stream/stream.el (streamp): Tiny optimization., Stefan Monnier, 2020/12/01
- [elpa] externals/stream 8239285 13/36: Fix compliler warnings in stream-tests.el, Stefan Monnier, 2020/12/01
- [elpa] externals/stream 18146ee 04/36: * packages/stream/stream.el: Update stream.el to v 1.1.0., Stefan Monnier, 2020/12/01
- [elpa] externals/stream 01fc059 03/36: * packages/stream/stream.el: Update stream to v 1.0.1., Stefan Monnier, 2020/12/01
- [elpa] externals/stream 1a61660 11/36: * stream.el: Implement `seqp' instead of `seq-p', Stefan Monnier, 2020/12/01
- [elpa] externals/stream 5762f78 21/36: Pinpoint semantics of `seq-subseq's implementation for streams, Stefan Monnier, 2020/12/01
- [elpa] externals/stream f384660 22/36: Add systematic tests against bogus element generation, Stefan Monnier, 2020/12/01
- [elpa] externals/stream ec86243 24/36: Some details in the documentation, Stefan Monnier, 2020/12/01
- [elpa] externals/stream b0c8949 28/36: Implement `seq-mapn' method for streams,
Stefan Monnier <=
- [elpa] externals/stream 7874a25 05/36: * packages/stream/tests/stream-tests.el: New tests., Stefan Monnier, 2020/12/01
- [elpa] externals/stream d77b733 09/36: Update stream.el to v2.0.2., Stefan Monnier, 2020/12/01
- [elpa] externals/stream fbe7ebd 06/36: Update stream.el to version 2.0.0, Stefan Monnier, 2020/12/01
- [elpa] externals/stream a8aa25c 07/36: * packages/stream/stream.el: Update stream.el to version 2.0.1., Stefan Monnier, 2020/12/01
- [elpa] externals/stream 2b2ba28 14/36: update stream.el to the latest version, Stefan Monnier, 2020/12/01
- [elpa] externals/stream 00e523f 15/36: Add stream stream-delay and stream-of-directory-files, Stefan Monnier, 2020/12/01
- [elpa] externals/stream ac42cc1 18/36: Fix some quoting problems in doc strings, Stefan Monnier, 2020/12/01
- [elpa] externals/stream a36469b 17/36: Add some more basic stream operations, Stefan Monnier, 2020/12/01
- [elpa] externals/stream f8e6639 20/36: * stream/stream.el (stream--generalizer): Accept more arguments, Stefan Monnier, 2020/12/01
- [elpa] externals/stream 873ee4e 23/36: Fix errors detected by tests added in last commit, Stefan Monnier, 2020/12/01