class Sass::Embedded::Channel

def connect(observer)
  @mutex.synchronize do
    begin
      id = @dispatcher.subscribe(observer)
    rescue EOFError
      @dispatcher = Dispatcher.new
      id = @dispatcher.subscribe(observer)
    end
    Connection.new(@dispatcher, id)
  end
end