class Sass::Embedded::Dispatcher

def initialize
  @compiler = Compiler.new
  @observers = {}
  @id = 0
  @mutex = Mutex.new
  Thread.new do
    loop do
      receive_message EmbeddedProtocol::OutboundMessage.decode @compiler.read
    rescue IOError, Errno::EBADF => e
      @mutex.synchronize do
        @id = PROTOCOL_ERROR_ID
        @observers.values
      end.each do |observer|
        observer.error e
      end
      break
    end
  end
end