小编R_B*_*_BD的帖子

在这里，我使用forkJoinrxjs来并行地订阅一个可观察对象数组。但是我要一个一个地订阅，什么是最好的解决方案？

下面是我的代码：

var observables = [];

Observable.forkJoin(observables)
    .subscribe(() => {
        this.msgs = [];
        this.msgs.push({
            severity: 'success',
            summary: 'Saved Successfully'
        });
        this.onSaveComplete();
    }, (error: any) => this.errorMessage = <any>error);
}, (error: any) => this.errorMessage = <any>error);

我是实体框架核心的新手，我正在制作一个简单的短项目。在我的项目中，我使用触发器。但是当我删除多个项目时，触发器显示错误：“阅读器关闭时调用 ReadAsync 的尝试无效”。

我谷歌了很多，但在这种情况下能够找到任何解决方案。我怎么解决这个问题？

下面是我的代码：

 Triggers<Items>.Deleted += async e => {
       decimal convertedQuantity = e.Entity.MeasurementUnitSetup.ConversionRatio * e.Entity.IssuedQuantity;
       var warehouseItem = e.Context.Entry(e.Entity.Warehouse).Collection(o => o.WarehouseItems)
                      .Query()
                      .SingleOrDefault(wi => wi.WarehouseId == e.Entity.WarehouseId && wi.MeasurementUnitSetup.ItemId == e.Entity.MeasurementUnitSetup.ItemId);

    if (warehouseItem.Quantity - convertedQuantity >= 0)
          warehouseItem.Quantity -= convertedQuantity;

    await e.Context.SaveChangesAsync(); //From here error showing
   }

提前致谢。