@@ -139,7 +139,9 @@ export class EntityOperators {
139139 source . pipe (
140140 mergeMap ( ( { info, criteria, correlationId } ) => {
141141 return this . entityService . loadMany ( info , criteria ) . pipe (
142- map ( ( ref : IEntityRef < TModel [ ] > ) => new LoadManySuccess < TModel > ( ref . info . modelType , ref . entity , correlationId ) ) ,
142+ map (
143+ ( ref : IEntityRef < TModel [ ] > ) => new LoadManySuccess < TModel > ( ref . info . modelType , ref . entity , correlationId )
144+ ) ,
143145 catchError ( ( error : IEntityError < TModel > ) =>
144146 handleError ( error , new LoadManyFailure < TModel > ( error . info . modelType , error . err , correlationId ) )
145147 )
@@ -154,7 +156,8 @@ export class EntityOperators {
154156 mergeMap ( ( { info, page, criteria, correlationId } ) => {
155157 return this . entityService . loadPage ( info , page , criteria ) . pipe (
156158 map (
157- ( ref : IEntityPageRef < TModel > ) => new LoadPageSuccess < TModel > ( ref . info . modelType , ref . entity , ref . pageInfo , correlationId )
159+ ( ref : IEntityPageRef < TModel > ) =>
160+ new LoadPageSuccess < TModel > ( ref . info . modelType , ref . entity , ref . pageInfo , correlationId )
158161 ) ,
159162 catchError ( ( error : IEntityError < TModel > ) =>
160163 handleError ( error , new LoadPageFailure < TModel > ( error . info . modelType , error . err , correlationId ) )
@@ -200,7 +203,10 @@ export class EntityOperators {
200203 source . pipe (
201204 mergeMap ( ( { info, entities, criteria, correlationId } ) => {
202205 return this . entityService . createMany < TModel > ( info , entities , criteria ) . pipe (
203- map ( ( ref : IEntityRef < TModel [ ] > ) => new CreateManySuccess < TModel > ( ref . info . modelType , ref . entity , correlationId ) ) ,
206+ map (
207+ ( ref : IEntityRef < TModel [ ] > ) =>
208+ new CreateManySuccess < TModel > ( ref . info . modelType , ref . entity , correlationId )
209+ ) ,
204210 catchError ( ( error : IEntityError < TModel > ) =>
205211 handleError ( error , new CreateManyFailure < TModel > ( error . info . modelType , error . err , correlationId ) )
206212 )
@@ -228,7 +234,10 @@ export class EntityOperators {
228234 source . pipe (
229235 mergeMap ( ( { info, entities, criteria, correlationId } ) => {
230236 return this . entityService . updateMany < TModel > ( info , entities , criteria ) . pipe (
231- map ( ( ref : IEntityRef < TModel [ ] > ) => new UpdateManySuccess < TModel > ( ref . info . modelType , ref . entity , correlationId ) ) ,
237+ map (
238+ ( ref : IEntityRef < TModel [ ] > ) =>
239+ new UpdateManySuccess < TModel > ( ref . info . modelType , ref . entity , correlationId )
240+ ) ,
232241 catchError ( ( error : IEntityError < TModel > ) =>
233242 handleError ( error , new UpdateManyFailure < TModel > ( error . info . modelType , error . err , correlationId ) )
234243 )
@@ -256,7 +265,10 @@ export class EntityOperators {
256265 source . pipe (
257266 mergeMap ( ( { info, entities, criteria, correlationId } ) => {
258267 return this . entityService . replaceMany < TModel > ( info , entities , criteria ) . pipe (
259- map ( ( ref : IEntityRef < TModel [ ] > ) => new ReplaceManySuccess < TModel > ( ref . info . modelType , ref . entity , correlationId ) ) ,
268+ map (
269+ ( ref : IEntityRef < TModel [ ] > ) =>
270+ new ReplaceManySuccess < TModel > ( ref . info . modelType , ref . entity , correlationId )
271+ ) ,
260272 catchError ( ( error : IEntityError < TModel > ) =>
261273 handleError ( error , new ReplaceManyFailure < TModel > ( error . info . modelType , error . err , correlationId ) )
262274 )
@@ -284,7 +296,10 @@ export class EntityOperators {
284296 source . pipe (
285297 mergeMap ( ( { info, entities, criteria, correlationId } ) => {
286298 return this . entityService . deleteMany < TModel > ( info , entities , criteria ) . pipe (
287- map ( ( ref : IEntityRef < TModel [ ] > ) => new DeleteManySuccess < TModel > ( ref . info . modelType , ref . entity , correlationId ) ) ,
299+ map (
300+ ( ref : IEntityRef < TModel [ ] > ) =>
301+ new DeleteManySuccess < TModel > ( ref . info . modelType , ref . entity , correlationId )
302+ ) ,
288303 catchError ( ( error : IEntityError < TModel > ) =>
289304 handleError ( error , new DeleteManyFailure < TModel > ( error . info . modelType , error . err , correlationId ) )
290305 )
@@ -295,32 +310,50 @@ export class EntityOperators {
295310
296311 select < TModel > ( ) {
297312 return ( source : Observable < Select < TModel > > ) =>
298- source . pipe ( map ( ( { info, entity, correlationId } ) => new Selected < TModel > ( info . modelType , entity , correlationId ) ) ) ;
313+ source . pipe (
314+ map ( ( { info, entity, correlationId } ) => new Selected < TModel > ( info . modelType , entity , correlationId ) )
315+ ) ;
299316 }
300317
301318 selectByKey < TModel > ( ) {
302319 return ( source : Observable < SelectByKey < TModel > > ) =>
303- source . pipe ( map ( ( { info, entityKey, correlationId } ) => new Selected < TModel > ( info . modelType , entityKey , correlationId ) ) ) ;
320+ source . pipe (
321+ map ( ( { info, entityKey, correlationId } ) => new Selected < TModel > ( info . modelType , entityKey , correlationId ) )
322+ ) ;
304323 }
305324
306325 selectMany < TModel > ( ) {
307326 return ( source : Observable < SelectMany < TModel > > ) =>
308- source . pipe ( map ( ( { info, entities, correlationId } ) => new SelectedMany < TModel > ( info . modelType , entities , correlationId ) ) ) ;
327+ source . pipe (
328+ map ( ( { info, entities, correlationId } ) => new SelectedMany < TModel > ( info . modelType , entities , correlationId ) )
329+ ) ;
309330 }
310331
311332 selectMore < TModel > ( ) {
312333 return ( source : Observable < SelectMore < TModel > > ) =>
313- source . pipe ( map ( ( { info, entities, correlationId } ) => new SelectedMore < TModel > ( info . modelType , entities , correlationId ) ) ) ;
334+ source . pipe (
335+ map ( ( { info, entities, correlationId } ) => new SelectedMore < TModel > ( info . modelType , entities , correlationId ) )
336+ ) ;
314337 }
315338
316339 selectManyByKeys < TModel > ( ) {
317340 return ( source : Observable < SelectManyByKeys < TModel > > ) =>
318- source . pipe ( map ( ( { info, entitiesKeys, correlationId } ) => new SelectedMany < TModel > ( info . modelType , entitiesKeys , correlationId ) ) ) ;
341+ source . pipe (
342+ map (
343+ ( { info, entitiesKeys, correlationId } ) =>
344+ new SelectedMany < TModel > ( info . modelType , entitiesKeys , correlationId )
345+ )
346+ ) ;
319347 }
320348
321349 selectMoreByKeys < TModel > ( ) {
322350 return ( source : Observable < SelectMoreByKeys < TModel > > ) =>
323- source . pipe ( map ( ( { info, entitiesKeys, correlationId } ) => new SelectedMore < TModel > ( info . modelType , entitiesKeys , correlationId ) ) ) ;
351+ source . pipe (
352+ map (
353+ ( { info, entitiesKeys, correlationId } ) =>
354+ new SelectedMore < TModel > ( info . modelType , entitiesKeys , correlationId )
355+ )
356+ ) ;
324357 }
325358
326359 deselect < TModel > ( ) {
@@ -330,12 +363,19 @@ export class EntityOperators {
330363
331364 deselectMany < TModel > ( ) {
332365 return ( source : Observable < DeselectMany < TModel > > ) =>
333- source . pipe ( map ( ( { info, entities, correlationId } ) => new DeselectedMany < TModel > ( info . modelType , entities , correlationId ) ) ) ;
366+ source . pipe (
367+ map ( ( { info, entities, correlationId } ) => new DeselectedMany < TModel > ( info . modelType , entities , correlationId ) )
368+ ) ;
334369 }
335370
336371 deselectManyByKeys < TModel > ( ) {
337372 return ( source : Observable < DeselectManyByKeys < TModel > > ) =>
338- source . pipe ( map ( ( { info, entitiesKeys, correlationId } ) => new DeselectedMany < TModel > ( info . modelType , entitiesKeys , correlationId ) ) ) ;
373+ source . pipe (
374+ map (
375+ ( { info, entitiesKeys, correlationId } ) =>
376+ new DeselectedMany < TModel > ( info . modelType , entitiesKeys , correlationId )
377+ )
378+ ) ;
339379 }
340380
341381 deselectAll < TModel > ( ) {
0 commit comments