WIP stdio line buffering

js/testing/testing.ts

@@ -13,6 +13,7 @@
    limitations under the License.
 */
 
+import { stdout } from "deno";
 export { assert, assertEqual, equal } from "./util";
 
 export type TestFunction = () => void | Promise<void>;
@@ -70,6 +71,11 @@ function green_ok() {
   return FG_GREEN + "ok" + RESET;
 }
 
+// Prints to stdout without newline.
+async function print(s: string): Promise<void> {
+  await stdout.write(new TextEncoder().encode(s));
+}
+
 async function runTests() {
   let passed = 0;
   let failed = 0;
@@ -78,7 +84,7 @@ async function runTests() {
   for (let i = 0; i < tests.length; i++) {
     const { fn, name } = tests[i];
     let result = green_ok();
-    console.log("test", name);
+    print(`test ${name}`);
     try {
       await fn();
       passed++;

src/resources.rs

@@ -43,14 +43,21 @@ pub type ResourceId = u32; // Sometimes referred to RID.
 // system ones.
 type ResourceTable = HashMap<ResourceId, Repr>;
 
+
+use std::os::unix::io::FromRawFd;
+
 lazy_static! {
   // Starts at 3 because stdio is [0-2].
   static ref NEXT_RID: AtomicUsize = AtomicUsize::new(3);
   static ref RESOURCE_TABLE: Mutex<ResourceTable> = Mutex::new({
     let mut m = HashMap::new();
     // TODO Load these lazily during lookup?
     m.insert(0, Repr::Stdin(tokio::io::stdin()));
-    m.insert(1, Repr::Stdout(tokio::io::stdout()));
+
+    let stdout = unsafe {std::fs::File::from_raw_fd(1)};
+    m.insert(1, Repr::Stdout(
+        tokio::fs::File::from_std(stdout)));
+
     m.insert(2, Repr::Stderr(tokio::io::stderr()));
     m
   });
@@ -59,7 +66,7 @@ lazy_static! {
 // Internal representation of Resource.
 enum Repr {
   Stdin(tokio::io::Stdin),
-  Stdout(tokio::io::Stdout),
+  Stdout(tokio::fs::File),
   Stderr(tokio::io::Stderr),
   FsFile(tokio::fs::File),
   TcpListener(tokio::net::TcpListener),