class Sass::Embedded::Channel

def subscribe(observer)
  @mutex.synchronize do
    begin
      id = @compiler.add_observer(observer)
    rescue ProtocolError
      @compiler = Compiler.new
      id = @compiler.add_observer(observer)
    end
    Subscription.new @compiler, observer, id
  end
end