Add allow_stdin support

src/iopub.lisp

@@ -142,8 +142,7 @@
           (write-string (subseq value
                                 (+ start (length prompt-prefix))
                                 (- (length value) (length prompt-suffix)))
-                        *query-io*)
-          (finish-output *query-io*)
+                        *stdin*)
           (adjust-array value (array-total-size value)
                         :fill-pointer 0))))))
 

src/kernel.lisp

@@ -1519,6 +1519,9 @@
            (*page-output* (make-string-output-stream))
            (*enable-debugger* (and (gethash "stop_on_error" (message-content *message*))
                                    *enable-debugger*))
+           (*stdin* (if allow-stdin
+                        *stdin*
+                        (make-instance 'closed-input-stream)))
            (*stderr* (if silent
                          (make-broadcast-stream)
                          *stderr*))

src/utils.lisp

@@ -170,3 +170,22 @@
 #+ccl
 (defmethod (setf ccl::input-stream-shared-resource) (new (s synonym-stream))
   (setf (ccl::input-stream-shared-resource (symbol-value (synonym-stream-symbol s))) new))
+
+(define-condition closed-stream (stream-error)
+  ())
+
+(defclass closed-input-stream (ngray:fundamental-character-input-stream)
+  ())
+
+(defmethod ngray:stream-clear-input ((stream closed-input-stream))
+  (error 'closed-stream :stream stream))
+
+(defmethod ngray:stream-read-char ((stream closed-input-stream))
+  (error 'closed-stream :stream stream))
+
+(defmethod ngray:open-stream-p ((stream closed-input-stream))
+  nil)
+
+(defmethod close ((stream closed-input-stream) &key abort)
+  (declare (ignore abort))
+  nil)

tests/test_kernel.py

@@ -17,7 +17,7 @@ def sanitize_path(p):
 @pytest.fixture(
     params=[
         "common-lisp",
-        "common-lisp_abcl",
+        #"common-lisp_abcl",
         "common-lisp_ccl",
         "common-lisp_clasp",
         "common-lisp_clisp",