diff options
| author | Kaz Kylheku <kaz@kylheku.com> | 2022-08-28 12:01:52 -0700 |
|---|---|---|
| committer | Kaz Kylheku <kaz@kylheku.com> | 2022-08-28 12:01:52 -0700 |
| commit | 1a3fe1a084fd68ff4f10ef8cf031f347563b79ca (patch) | |
| tree | 00f541955af1672e133064ef69abd976a15ec095 /stdlib | |
| parent | a2e0d566ef4d45d4915d43d035f6f21270d70178 (diff) | |
| download | txr-1a3fe1a084fd68ff4f10ef8cf031f347563b79ca.tar.gz txr-1a3fe1a084fd68ff4f10ef8cf031f347563b79ca.tar.bz2 txr-1a3fe1a084fd68ff4f10ef8cf031f347563b79ca.zip | |
New macro: close-lazy-streams.
* lib.c (lazy_stream_s): New symbol variable.
(lazy_streams_binding): New static variable.
(lazy_stream_register): New static function
(lazy_stream_cons): If the stream is associated with
a lazy cons, register it with lazy_stream_register.
(obj_init): gc-protect lazy_streams_binding variable.
Intern the sys:*lazy-streams* symbol.
* lib.h (lazy_streams_s): Declared.
* eval.c (eval_init): Register sys:*lazy-streams*
special variable.
* stdlib/getput.tl (close-lazy-streams): New macro.
* autoload.c (getput_set_entries): Trigger autload on
close-lazy-streams symbol.
* txr.1: Documented.
* stdlib/doc-syms.tl: Updated.
Diffstat (limited to 'stdlib')
| -rw-r--r-- | stdlib/doc-syms.tl | 1 | ||||
| -rw-r--r-- | stdlib/getput.tl | 6 |
2 files changed, 7 insertions, 0 deletions
diff --git a/stdlib/doc-syms.tl b/stdlib/doc-syms.tl index 5d056427..e9685e70 100644 --- a/stdlib/doc-syms.tl +++ b/stdlib/doc-syms.tl @@ -338,6 +338,7 @@ ("clock-t" "N-01B6F219") ("clockid-t" "N-01153D9E") ("close" "D-0016") + ("close-lazy-streams" "N-00B8ACD5") ("close-stream" "N-00596930") ("closedir" "N-01FEE88A") ("closelog" "N-02CEE7EA") diff --git a/stdlib/getput.tl b/stdlib/getput.tl index 0cf751a1..a1be729e 100644 --- a/stdlib/getput.tl +++ b/stdlib/getput.tl @@ -187,3 +187,9 @@ (defun command-put-jsons (cmd seq : flat-p mopt) (with-stream (s (open-command cmd `w@mopt`)) (put-jsons seq s flat-p))) + +(defmacro close-lazy-streams (. body) + ^(let ((sys:*lazy-streams*)) + (unwind-protect + (progn ,*body)) + (mapdo (fun close-stream) sys:*lazy-streams*))) |