create method

@override Future<void> create(T entity)

Create a new entity.

Implementation

@override
Future<void> create(T entity) async {
  final existed = _storage[entity.userId]?.containsKey(entity.id) ?? false;
  _storage.putIfAbsent(entity.userId, () => {})[entity.id] = entity;
  _emit(entity.id, entity.userId, existed ? DatumOperationType.update : DatumOperationType.create, entity);
}