Process StepStartedEvent. New step will be created and added to
stepStorage.

@param event to process
10605
public void fire(StepStartedEvent event) {
        Step step = new Step();
        event.process(step);
        stepStorage.put(step);

        notifier.fire(event);
    }
1001509
@Handler
    public void onStart(Start event) {
        synchronized (this) {
            if (runner != null && !runner.isInterrupted()) {
                return;
            }
            runner = new Thread(this, Components.simpleObjectName(this));
            runner.start();
        }
    }
664045
@Override
    public void onSelection(SelectionEvent<MaterialStep> event) {
        if (stepSkippingAllowed) {
            if (event.getSelectedItem().getState() == State.SUCCESS) {
                goToStep(event.getSelectedItem());
            }
        }
    }
174986
@Override
    public synchronized void dispatch(@NonNull Event event) {
        String type = event.type;
        List<EventHandlerWrapper> eventHandlers = subscribers.get(type);
        if (eventHandlers != null) {
            EventHandlerWrapper handler = null;
            for (int i = 0, size = eventHandlers.size(); i < size; i++) {
                handler = eventHandlers.get(i);
                if (handler.eventHandlerReceiver != null) {
                    handler.handleEvent(event);
                } else {
                    if (!TextUtils.isEmpty(handler.producer) && handler.producer.equals(event.sourceId)
                            || TextUtils.isEmpty(handler.producer)) {
                        handler.handleEvent(event);
                    }
                }
            }
        }
    }
422517
public void processEvent(ContentEvent event, int counter) {
		if (this.piInstances == null || this.piInstances.size() < this.getParallelism())
			throw new IllegalStateException("ThreadsWorkerProcessingItem(s) need to be setup before process any event (i.e. in ThreadsTopology.start()).");
		
		ThreadsProcessingItemInstance piInstance = this.piInstances.get(counter);
		ThreadsEventRunnable runnable = new ThreadsEventRunnable(piInstance, event);
		ThreadsEngine.getThreadWithIndex(piInstance.getThreadIndex()).submit(runnable);
	}
190592
@Override
    public void process(Step step) {
        Attachment attachment = writeAttachmentSafely(getAttachment(), getTitle(), getType());
        step.getAttachments().add(attachment);
    }
218534
def process(self, event):
        
        logger.info(f"{self}: put {event.src_path}")
        self.queue.put(os.path.basename(event.src_path))
1160602
public void addEvent(E event) {
    CompletableFuture<E> future = futures.poll();
    if (future != null) {
      future.complete(event);
    } else {
      events.add(event);
      if (events.size() > 100) {
        events.remove();
      }
    }
  }
470505
public void doPost(final LoggingEvent event) {
        // if event does not meet threshold, exit now
        if (!isAsSevereAsThreshold(event.getLevel())) {
            return;
        }

        // get the "local" logger for this event from the
        // configured repository.
        Logger localLogger =
                getLoggerRepository().getLogger(event.getLoggerName());

        // if the logger level is greater or equal to the level
        // of the event, use the logger to append the event.
        if (event.getLevel()
                .isGreaterOrEqual(localLogger.getEffectiveLevel())) {
            // call the loggers appenders to process the event
            localLogger.callAppenders(event);
        }
  }
1317551
private void processEvent(EventModel<?> event) {
        if (!event.getSource().isCreatedFromInstance()) {
            error("event: " + event + "has invalid source");
            return;
        }
        debug("EventFired: " + event.toString() + " from " + event.getSource().getID());
        submit(() -> event.lifecycleCallback(EventLifeCycle.START));

        if (checkEventsControllers(event)) {
            submit(() -> event.lifecycleCallback(EventLifeCycle.APPROVED));
            submit(() -> event.lifecycleCallback(EventLifeCycle.RESOURCE));
            List<ResourceModel> resourceList = getMain().getResourceManager().generateResources(event);
            event.addResources(resourceList);
            submit(() -> event.lifecycleCallback(EventLifeCycle.LISTENERS));
            List<EventListenerModel> listenersTemp = event.getAllInformations().parallelStream()
                    .map(listeners::get)
                    .filter(Objects::nonNull)
                    .flatMap(Collection::stream)
                    .distinct()
                    .collect(Collectors.toList());

            List<CompletableFuture> futures = listenersTemp.stream()
                    .map(eventListener -> submit(() -> eventListener.eventFired(event)))
                    .collect(Collectors.toList());
            try {
                timeOut(futures, 1000);
            } catch (InterruptedException e) {
                error("interrupted", e);
            }
            submit(() -> event.lifecycleCallback(EventLifeCycle.OUTPUT));
            getMain().getOutputManager().passDataToOutputPlugins(event);
            submit(() -> event.lifecycleCallback(EventLifeCycle.ENDED));
            List<EventListenerModel> finishListenersTemp = event.getAllInformations().parallelStream()
                    .map(finishListeners::get)
                    .filter(Objects::nonNull)
                    .flatMap(Collection::stream)
                    .distinct()
                    .collect(Collectors.toList());

            futures = finishListenersTemp.stream()
                    .map(eventListener -> submit(() -> eventListener.eventFired(event)))
                    .collect(Collectors.toList());

            try {
                timeOut(futures, 1000);
            } catch (InterruptedException e) {
                error("interrupted", e);
            }
        } else {
            debug("canceling: " + event.toString() + " from " + event.getSource().getID());
            submit(() -> event.lifecycleCallback(EventLifeCycle.CANCELED));
        }
    }
1073743
protected final Event processEvent() throws IOException {
    while (true) {
      String line;
      try {
        line = readLine();
      } catch (final EOFException ex) {
        if (doneOnce) {
          throw ex;
        }
        doneOnce = true;
        line = "";
      }

      // If the line is empty (a blank line), Dispatch the event, as defined below.
      if (line.isEmpty()) {
        // If the data buffer is an empty string, set the data buffer and the event name buffer to
        // the empty string and abort these steps.
        if (dataBuffer.length() == 0) {
          eventName = "";
          continue;
        }

        // If the event name buffer is not the empty string but is also not a valid NCName,
        // set the data buffer and the event name buffer to the empty string and abort these steps.
        // NOT IMPLEMENTED

        final Event.Builder eventBuilder = new Event.Builder();
        eventBuilder.withEventName(eventName.isEmpty() ? Event.MESSAGE_EVENT : eventName);
        eventBuilder.withData(dataBuffer.toString());

        // Set the data buffer and the event name buffer to the empty string.
        dataBuffer = new StringBuilder();
        eventName = "";

        return eventBuilder.build();
        // If the line starts with a U+003A COLON character (':')
      } else if (line.startsWith(":")) {
        // ignore the line
        // If the line contains a U+003A COLON character (':') character
      } else if (line.contains(":")) {
        // Collect the characters on the line before the first U+003A COLON character (':'),
        // and let field be that string.
        final int colonIdx = line.indexOf(":");
        final String field = line.substring(0, colonIdx);

        // Collect the characters on the line after the first U+003A COLON character (':'),
        // and let value be that string.
        // If value starts with a single U+0020 SPACE character, remove it from value.
        String value = line.substring(colonIdx + 1);
        value = value.startsWith(" ") ? value.substring(1) : value;

        processField(field, value);
      // Otherwise, the string is not empty but does not contain a U+003A COLON character (':')
      // character
      } else {
        processField(line, "");
      }
    }
  }
1285796
public void handleEvent(Event event) {
        String topic = event.getTopic();
        if (topic.equals(TOPIC_QUEUED_WORK_NAME)) {
            Runnable r = event.getProperty(KEY_RUNNABLE, Runnable.class);
            if (null != r) {
                r.run();
            } else {
                if (TraceComponent.isAnyTracingEnabled() && tc.isEventEnabled()) {
                    Tr.event(tc, "Unable to find runnable in event; " + topic);
                }
            }
        }
    }
396817
private void runInitializationStage(Event event) {
		// Immediate synchronous dispatching of Initialize event
		try {
			setOwnerState(OwnerState.INITIALIZING);
			try {
				this.eventDispatcher.immediateDispatch(event);
			} finally {
				setOwnerState(OwnerState.ALIVE);
			}
			this.agentAsEventListener.fireEnqueuedEvents(this);
			if (this.agentAsEventListener.isKilled.get()) {
				this.agentAsEventListener.killOwner(InternalEventBusSkill.this);
			}
		} catch (Exception e) {
			// Log the exception
			final Logging loggingCapacity = getLoggingSkill();
			if (loggingCapacity != null) {
				loggingCapacity.error(Messages.InternalEventBusSkill_3, e);
			} else {
				final LogRecord record = new LogRecord(Level.SEVERE, Messages.InternalEventBusSkill_3);
				this.logger.getKernelLogger().log(
						this.logger.prepareLogRecord(record, this.logger.getKernelLogger().getName(),
								Throwables.getRootCause(e)));
			}
			// If we have an exception within the agent's initialization, we kill the agent.
			setOwnerState(OwnerState.ALIVE);
			// Asynchronous kill of the event.
			this.agentAsEventListener.killOrMarkAsKilled();
		}
	}
690889
@Override
	public void processEvent(ComponentSystemEvent event) throws AbortProcessingException {
		if (event instanceof PostAddToViewEvent) {
			if ("non-sticky".equals(getFixed()) || ("bottom".equals(getPosition()) && (!isSticky()))) {
				AddResourcesListener.addExtCSSResource("sticky-footer-navbar.css");
				/*UIOutput resource = new UIOutput();
				resource.getAttributes().put("name", "css/sticky-footer-navbar.css");
				resource.getAttributes().put("library", C.BSF_LIBRARY);
				resource.getAttributes().put("target", "head");
				resource.setRendererType("javax.faces.resource.Stylesheet");
				FacesContext.getCurrentInstance().getViewRoot().addComponentResource(FacesContext.getCurrentInstance(),
						resource);*/
			}
		}
		super.processEvent(event);
	}
99568
function(event) {

        event.preventDefault();

        if (window.kelmu.data[id].undoStackPointer < window.kelmu.data[id].undoStack.length - 1) {

          var sp = window.kelmu.data[id].undoStackPointer;
          if (window.kelmu.data[id].undoStack[sp + 1][0] !== window.kelmu.data[id].stepNumber) {
            originalRedo(event);
          }

          window.kelmu.data[id].undoStackPointer += 1;
          sp = window.kelmu.data[id].undoStackPointer;
          window.kelmu.data[id].stepNumber = window.kelmu.data[id].undoStack[sp][0];
          window.kelmu.data[id].subStepNumber = window.kelmu.data[id].undoStack[sp][1];

          createAnnotations();
          if (window.kelmu.data[id].actions.updateEditor) {
            window.kelmu.data[id].actions.updateEditor(true, true);
          }

        }

      }
283136
@Override
	public void processEvent(SystemEvent event) throws AbortProcessingException {
		if (!FacesContext.getCurrentInstance().isPostback()) {
			// if (!(getParent() instanceof Column)) {
			insertLabelBeforeThisInputField();
			insertMessageBehindThisInputField();
		}
		// }
	}
1139684
private function captureStepEvent(StepTested $event)
    {
        if ($event instanceof AfterStepSetup) {
            $this->stepBeforeTestedEvents[$event->getStep()->getLine()] = $event;
        } else {
            $this->stepAfterTestedEvents[$event->getStep()->getLine()] = $event;
        }
    }