File tree Expand file tree Collapse file tree 3 files changed +10
-2
lines changed Expand file tree Collapse file tree 3 files changed +10
-2
lines changed Original file line number Diff line number Diff line change @@ -302,6 +302,14 @@ public function setWriteCount($writeCount)
302
302
return $ this ;
303
303
}
304
304
305
+ /**
306
+ * Increment the write count by 1
307
+ */
308
+ public function incrementWriteCount ()
309
+ {
310
+ $ this ->writeCount ++;
311
+ }
312
+
305
313
/**
306
314
* Returns the current number of items filtered out of this execution
307
315
*
Original file line number Diff line number Diff line change @@ -32,5 +32,5 @@ interface ItemReaderInterface
32
32
* @throws \Exception if an there is a non-specific error.
33
33
* @return null|mixed Returns false in case of reading error
34
34
*/
35
- public function read (StepExecution $ stepExecution );
35
+ public function read ();
36
36
}
Original file line number Diff line number Diff line change @@ -166,7 +166,7 @@ public function doExecute(StepExecution $stepExecution)
166
166
167
167
$ this ->initializeStepComponents ($ stepExecution );
168
168
169
- while (($ item = $ this ->reader ->read ($ stepExecution )) !== null ) {
169
+ while (($ item = $ this ->reader ->read ()) !== null ) {
170
170
if (false === $ item ) {
171
171
$ this ->dispatchStepExecutionEvent (EventInterface::INVALID_READER_EXECUTION , $ stepExecution );
172
172
continue ;
You can’t perform that action at this time.
0 commit comments