class Sass::Embedded::Dispatcher

def subscribe(observer)
  @mutex.synchronize do
    raise EOFError if half_closed?
    id = @id
    @id = id.next
    @observers[id] = observer
    id
  end
end