class Selective::Ruby::Core::NamedPipe

def write(message)
  return unless write_pipe
  chunk_size = 1024  # 1KB chunks
  offset = 0
  begin
    while offset < message.bytesize
      chunk = message.byteslice(offset, chunk_size)
      write_pipe.write(chunk)
      write_pipe.flush
      offset += chunk_size
    end
    write_pipe.write("\n")
    write_pipe.flush
  rescue Errno::EPIPE
    raise PipeClosedError
  end
end