package Ġio . hol unda . camunda . task pool . view Ċ Ċ /** Ċ Ġ* ĠRepresents Ġa Ġjoined Ġentity Ġof Ġa Ġtask Ġwith Ġcorre lated Ġdata Ġentries . Ċ Ġ*/ Ċ data Ġclass ĠTask WithData Entries ( ĊĠ Ġ/** ĊĠĠ Ġ* ĠTask Ġfrom Ġthe Ġengine . ĊĠĠ Ġ*/ ĊĠ Ġval Ġtask : ĠTask , ĊĠ Ġ/** ĊĠĠ Ġ* ĠList Ġof Ġdata Ġentries , Ġbound Ġusing Ġtask Ġcorrelation Ġids . ĊĠĠ Ġ*/ ĊĠ Ġval Ġdata Entries : ĠList < Data Entry > Ġ= ĠlistOf () Ċ ) Ġ{ ĊĠ Ġcompanion Ġobject Ġ{ ĊĠĠĠ Ġ/** ĊĠĠĠĠ Ġ* ĠHelper Ġfunction Ġto Ġcorre late . ĊĠĠĠĠ Ġ*/ ĊĠĠĠ Ġfun Ġcorre late ( task : ĠTask , Ġdata Entries : ĠList < Data Entry >): ĠTask WithData Entries Ġ= ĊĠĠĠĠĠ ĠTask WithData Entries ( ĊĠĠĠĠĠĠĠ Ġtask Ġ= Ġtask , ĊĠĠĠĠĠĠĠ Ġdata Entries Ġ= Ġdata Entries . filter Ġ{ Ġentry Ġ-> ĊĠĠĠĠĠĠĠĠĠ Ġ// Ġtask Ġcorrelation Ġlist Ġcontains Ġentry Type Ġ-> Ġentry Id Ġelements ĊĠĠĠĠĠĠĠĠĠ Ġ// Ġcreate Ġdata Ġentry Ġidentity Ġwith Ġit Ġand Ġtake Ġonly Ġdata Ġentries Ġwith Ġthis Ġidentity ĊĠĠĠĠĠĠĠĠĠ Ġtask . correlation Id entities . contains ( entry . identity ) ĊĠĠĠĠĠĠĠ Ġ}. toList () ĊĠĠĠĠĠ Ġ) ĊĊĠĠĠ Ġ/** ĊĠĠĠĠ Ġ* ĠHelper Ġfunction Ġto Ġcorre late . ĊĠĠĠĠ Ġ*/ ĊĠĠĠ Ġfun Ġcorre late ( tasks : ĠList < Task >, Ġdata Entry : ĠData Entry ): ĠList < Task WithData Entries > Ġ= ĊĠĠĠĠĠ Ġtasks . filter Ġ{ Ġit . correlation Id entities . contains ( data Entry . identity ) Ġ} ĊĠĠĠĠĠĠĠ Ġ. map Ġ{ ĠTask WithData Entries ( it , ĠlistOf ( data Entry )) Ġ} ĊĠĠĠĠĠĠĠ Ġ. toList () ĊĊĠĠĠ Ġ/** ĊĠĠĠĠ Ġ* ĠHelper Ġfunction Ġto Ġcorre late . ĊĠĠĠĠ Ġ*/ ĊĠĠĠ Ġfun Ġcorre late ( tasks : ĠList < Task >, Ġdata Entries : ĠList < Data Entry >) Ġ= ĊĠĠĠĠĠ Ġtasks . map Ġ{ Ġcorre late ( it , Ġdata Entries ) Ġ} ĊĠ Ġ} Ċ } Ċ