diff --git a/src/engine.rs b/src/engine.rs
index 884b64e0..f7f68602 100644
--- a/src/engine.rs
+++ b/src/engine.rs
@@ -1,15 +1,13 @@
 use anyhow::{anyhow, Result};
 use rust_embed::RustEmbed;
+use std::string::String;
 use std::{collections::HashSet, io::Cursor, path::PathBuf};
 use wasi_common::{I32Exit, WasiCtx};
 use wasmtime::{AsContextMut, Config, Engine, Linker, Module, ResourceLimiter, Store};
 
-use crate::{
-    function_run_result::{
-        FunctionOutput::{self, InvalidJsonOutput, JsonOutput},
-        FunctionRunResult, InvalidOutput,
-    },
-    logs::LogStream,
+use crate::function_run_result::{
+    FunctionOutput::{self, InvalidJsonOutput, JsonOutput},
+    FunctionRunResult, InvalidOutput,
 };
 
 #[derive(Clone)]
@@ -130,7 +128,7 @@ pub fn run(params: FunctionRunParams) -> Result<FunctionRunResult> {
 
     let input_stream = wasi_common::pipe::ReadPipe::new(Cursor::new(input.clone()));
     let output_stream = wasi_common::pipe::WritePipe::new_in_memory();
-    let error_stream = wasi_common::pipe::WritePipe::new(LogStream::default());
+    let error_stream = wasi_common::pipe::WritePipe::new_in_memory();
 
     let memory_usage: u64;
     let instructions: u64;
@@ -195,9 +193,10 @@ pub fn run(params: FunctionRunParams) -> Result<FunctionRunResult> {
 
     let mut logs = error_stream
         .try_into_inner()
-        .expect("Log stream reference still exists");
+        .expect("Log stream reference still exists")
+        .into_inner();
 
-    logs.append(error_logs.as_bytes());
+    logs.extend_from_slice(error_logs.as_bytes());
 
     let raw_output = output_stream
         .try_into_inner()
@@ -228,7 +227,7 @@ pub fn run(params: FunctionRunParams) -> Result<FunctionRunResult> {
         size,
         memory_usage,
         instructions,
-        logs: logs.to_string(),
+        logs: String::from_utf8_lossy(&logs).into(),
         input: function_run_input,
         output,
         profile: profile_data,
diff --git a/src/lib.rs b/src/lib.rs
index f4bf5142..a7f46265 100644
--- a/src/lib.rs
+++ b/src/lib.rs
@@ -1,5 +1,4 @@
 pub mod bluejay_schema_analyzer;
 pub mod engine;
 pub mod function_run_result;
-pub mod logs;
 pub mod scale_limits_analyzer;
diff --git a/src/logs.rs b/src/logs.rs
deleted file mode 100644
index 02db2586..00000000
--- a/src/logs.rs
+++ /dev/null
@@ -1,88 +0,0 @@
-use core::fmt;
-use std::io;
-
-#[derive(Debug)]
-pub struct LogStream {
-    logs: Vec<String>,
-    current_bytesize: usize,
-}
-
-impl Default for LogStream {
-    fn default() -> Self {
-        let logs = Vec::new();
-        let current_bytesize = 0;
-        Self {
-            logs,
-            current_bytesize,
-        }
-    }
-}
-
-impl fmt::Display for LogStream {
-    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
-        for message in &self.logs {
-            write!(f, "{message}")?;
-        }
-        Ok(())
-    }
-}
-
-impl io::Write for LogStream {
-    fn write(&mut self, buf: &[u8]) -> io::Result<usize> {
-        Ok(self.append(buf))
-    }
-
-    fn flush(&mut self) -> io::Result<()> {
-        Ok(())
-    }
-}
-
-impl LogStream {
-    /// Append a buffer to the log stream.
-    ///
-    /// # Arguments
-    /// * `buf` - the buffer to append
-    pub fn append(&mut self, buf: &[u8]) -> usize {
-        let log = String::from_utf8_lossy(buf);
-
-        let log_length = log.len();
-        self.current_bytesize += log_length;
-        self.logs.push(log.into());
-
-        log_length
-    }
-
-    #[must_use]
-    pub fn last(&self) -> Option<&String> {
-        self.logs.last()
-    }
-
-    #[must_use]
-    pub fn last_message(&self) -> Option<&str> {
-        self.logs.last().map(String::as_str)
-    }
-}
-
-#[cfg(test)]
-mod tests {
-    use super::*;
-
-    #[test]
-    fn test_bounded_log() {
-        let mut bounded_log = LogStream::default();
-        let log = b"hello world";
-        bounded_log.append(log);
-        assert_eq!(Some("hello world"), bounded_log.last_message());
-    }
-
-    #[test]
-    fn test_display() {
-        let mut logs = LogStream::default();
-        assert_eq!(String::new(), logs.to_string());
-
-        logs.append(b"hello");
-        logs.append(b"world");
-
-        assert_eq!("helloworld", logs.to_string());
-    }
-}