def create(self, **kwargs):
        obj = self.model(**kwargs)
        self._for_write = True
        obj.save(force_insert=True, using=self.db)
        return obj
Test yielding on the watchman response to the initial subscribe command.
dataset/ETHPy150Open AppScale/appscale/AppServer/lib/django-1.5/django/db/models/query.py/QuerySet.create--crossover with--dataset/ETHPy150Open pantsbuild/pants/tests/python/pants_test/pantsd/test_watchman.py/TestWatchman.test_subscribed_response