add method

@override void add(List<int> event)

Adds a splitted byte SSE event to the output sink.

Implementation

@override
void add(List<int> event) {
  try {
    for (final splittedEvent in filterBetweenSeparator(event)) {
      addToSink(splittedEvent);
    }
  } catch (e) {
    final exeption = ByteStreamSplitException(
      message: "Failed to split SSE",
      source: event,
      originalExeption: e,
    );
    addError(exeption);
    dev.log(exeption.toString());
    dev.inspect(event);
  }
}