@@ -91,14 +91,16 @@ class TokenIssuedEndpoint extends Endpoint {
9191 }
9292
9393 Future <TokenIssued > update (Session session, TokenIssued tokenIssued) async {
94+ final item = await TokenIssued .db.updateRow (session, tokenIssued);
9495 _updateStream (session);
95- return await TokenIssued .db. updateRow (session, tokenIssued) ;
96+ return item ;
9697 }
9798
9899 Future <List <TokenIssued >> updateAll (
99100 Session session, List <TokenIssued > tokenIssuedList) async {
101+ final listNew = await TokenIssued .db.update (session, tokenIssuedList);
100102 _updateStream (session);
101- return await TokenIssued .db. update (session, tokenIssuedList) ;
103+ return listNew ;
102104 }
103105
104106 Future <List <TokenIssued >> resetAll (Session session, int windowId) async {
@@ -107,8 +109,9 @@ class TokenIssuedEndpoint extends Endpoint {
107109 for (TokenIssued issued in list) {
108110 issued.reset = true ;
109111 }
112+ final listNew = await TokenIssued .db.update (session, list);
110113 _updateStream (session);
111- return await TokenIssued .db. update (session, list) ;
114+ return listNew ;
112115 }
113116
114117 Future <TokenIssued ?> create (Session session, TokenIssued tokenIssued) async {
@@ -123,8 +126,8 @@ class TokenIssuedEndpoint extends Endpoint {
123126 }
124127
125128 Future <void > delete (Session session, TokenIssued tokenIssued) async {
126- _updateStream (session);
127129 await TokenIssued .db.deleteRow (session, tokenIssued);
130+ _updateStream (session);
128131 }
129132
130133 Future <int > countIsQueueStatus (Session session, int windowId) async {
0 commit comments