AttachmentsStore.java 文件源码

@Override
public Single<int[]> attachDbos(int accountId, int attachToType, int attachToDbid, @NonNull List<Entity> entities) {
    return Single.create(emitter -> {
        ArrayList<ContentProviderOperation> operations = new ArrayList<>(entities.size());

        int[] indexes = new int[entities.size()];
        for (int i = 0; i < entities.size(); i++) {
            Entity entity = entities.get(i);
            indexes[i] = appendAttachOperationWithStableAttachToId(operations, accountId, attachToType, attachToDbid, entity);
        }

        ContentProviderResult[] results = getContentResolver().applyBatch(MessengerContentProvider.AUTHORITY, operations);

        int [] ids = new int[entities.size()];

        for (int i = 0; i < indexes.length; i++) {
            ContentProviderResult result = results[indexes[i]];
            int dbid = Integer.parseInt(result.uri.getPathSegments().get(1));
            ids[i] = dbid;
        }

        emitter.onSuccess(ids);
    });
}