@@ -16,7 +16,6 @@ public class ObserverBuilder {
1616 private Query .IterCallback iterCallback ;
1717 private Query .RunCallback runCallback ;
1818 private Query .EntityCallback entityCallback ;
19- private Iter iter ;
2019 private static final long TERM_SIZE = ecs_term_t .layout ().byteSize ();
2120 private static final int MAX_EVENTS = 8 ;
2221
@@ -26,7 +25,6 @@ public ObserverBuilder(World world) {
2625 this .desc = ecs_observer_desc_t .allocate (this .arena );
2726 this .termCount = 0 ;
2827 this .eventCount = 0 ;
29- this .iter = null ;
3028 }
3129
3230 public ObserverBuilder (World world , String name ) {
@@ -163,12 +161,8 @@ public FlecsObserver iter(Query.IterCallback callback) {
163161 this .iterCallback = callback ;
164162
165163 MemorySegment callbackStub = ecs_iter_action_t .allocate (it -> {
166- if (this .iter == null ) {
167- this .iter = new Iter (it , this .world );
168- } else {
169- iter .setNativeIter (it );
170- }
171- callback .accept (this .iter );
164+ Iter iter = new Iter (it , this .world );
165+ callback .accept (iter );
172166 }, this .world .arena ());
173167
174168 ecs_observer_desc_t .callback (this .desc , callbackStub );
@@ -180,12 +174,8 @@ public FlecsObserver run(Query.RunCallback callback) {
180174 this .runCallback = callback ;
181175
182176 MemorySegment callbackStub = ecs_run_action_t .allocate (it -> {
183- if (this .iter == null ) {
184- this .iter = new Iter (it , this .world );
185- } else {
186- iter .setNativeIter (it );
187- }
188- callback .accept (this .iter );
177+ Iter iter = new Iter (it , this .world );
178+ callback .accept (iter );
189179 }, this .world .arena ());
190180
191181 ecs_observer_desc_t .run (this .desc , callbackStub );
0 commit comments