observers/enqueue_event

• C

  View on GitHub

  #include <enqueue_event.h>
  #include <stdio.h>
   
  // This is the same example as custom_event, but instead of emit() the example
  // uses the enqueue() function. Whereas emit() invokes observers synchronously,
  // enqueue() adds the event to the command queue, which delays invoking 
  // observers until the next time the command queue is flushed.
   
  typedef struct {
      double x, y;
  } Position;
   
  void Observer(ecs_iter_t *it) {
      ecs_world_t *ecs = it->stage;
      
      // The event kind
      ecs_entity_t event = it->event;
   
      // The (component) id for which the event was emitted
      ecs_entity_t event_id = it->event_id;
   
      for (int i = 0; i < it->count; i ++) {
          ecs_entity_t e = it->entities[i];
   
          printf(" - %s: %s: %s\n", 
              ecs_get_name(ecs, event), 
              ecs_get_name(ecs, event_id),
              ecs_get_name(ecs, e));
      }
  }
   
  int main(int argc, char *argv[]) {
      ecs_world_t *ecs = ecs_init_w_args(argc, argv);
   
      ECS_COMPONENT(ecs, Position);
   
      // Create custom event
      ecs_entity_t MyEvent = ecs_entity(ecs, { .name = "MyEvent" });
   
      // Create observer for custom event
      ECS_OBSERVER(ecs, Observer, MyEvent, Position);
   
      // Create entity
      ecs_entity_t e = ecs_entity(ecs, { .name = "e" });
      
      // The observer query can be matched against the entity, so make sure it
      // has the Position component before emitting the event. This does not 
      // trigger the observer yet.
      ecs_set(ecs, e, Position, {10, 20});
   
      ecs_world_t *stage_1 = ecs_is_stage(ecs) ? ecs : ecs_get_stage(ecs, 0);
   
      // Emit the custom event
      ecs_enqueue(stage_1, &(ecs_event_desc_t) {
          .event = MyEvent,
          .ids = &(ecs_type_t){ (ecs_id_t[]){ ecs_id(Position) }, 1 }, // 1 id
          .entity = e
      });
      
      printf("Event enqueued!\n");
   
      // Flushes the queue, and invokes the observer
      ecs_merge(stage_1);
   
      ecs_fini(ecs);
   
      // Output
      //   Event enqueued!
      //    - MyEvent: Position: e
  }

• C++

  View on GitHub

  #include <enqueue_event.h>
  #include <iostream>
   
  // This is the same example as custom_event, but instead of emit() the example
  // uses the enqueue() method. Whereas emit() invokes observers synchronously,
  // enqueue() adds the event to the command queue, which delays invoking 
  // observers until the next time the command queue is flushed.
   
  struct Position {
      double x, y;
  };
   
  // Create tag type to use as event (could also use entity)
  struct MyEvent { };
   
  int main(int, char *[]) {
      flecs::world ecs;
   
      // Create observer for custom event
      ecs.observer<Position>()
          .event<MyEvent>()
          .each([](flecs::iter& it, size_t i, Position&) {
              std::cout << " - " << it.event().name() << ": " 
                  << it.event_id().str() << ": "
                  << it.entity(i).name() << "\n";
          });
   
      // The observer query can be matched against the entity, so make sure it
      // has the Position component before emitting the event. This does not 
      // trigger the observer yet.
      flecs::entity e = ecs.entity("e")
          .set<Position>({10, 20});
   
      flecs::world stage_1 = ecs.get_stage(0);
   
      // Emit the custom event
      stage_1.event<MyEvent>()
          .id<Position>()
          .entity(e)
          .enqueue();
   
      std::cout << "Event enqueued!\n";
   
      // Flushes the queue, and invokes the observer
      stage_1.merge();
   
      // Output
      //  Event enqueued!
      //   - MyEvent: Position: e
  }