class Sass::Embedded::Compiler

def close
  @stdin_mutex.synchronize do
    @stdin.close unless @stdin.closed?
    @stdout.close unless @stdout.closed?
    @stderr.close unless @stderr.closed?
  end
  @wait_thread.value
end

def closed?
  @stdin_mutex.synchronize do
    @stdin.closed?
  end
end

def initialize
  @stdin, @stdout, @stderr, @wait_thread = Open3.popen3(PATH, chdir: __dir__)
  @stdin.binmode
  @stdout.binmode
  @stdin_mutex = Mutex.new
  @stdout_mutex = Mutex.new
  Thread.new do
    loop do
      warn(@stderr.readline, uplevel: 1)
    rescue IOError, Errno::EBADF
      break
    end
  end
end

def read
  @stdout_mutex.synchronize do
    length = Varint.read(@stdout)
    @stdout.read(length)
  end
end

def write(payload)
  @stdin_mutex.synchronize do
    Varint.write(@stdin, payload.length)
    @stdin.write(payload)
  end
end