add method

  1. @override
void add(
  1. List<int> event
)
override

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, stacktrace) {
    final exception = ByteStreamSplitException(
      message: "Failed to split SSE",
      source: event,
      originalException: e,
    );
    addError(exception, stacktrace);
  }
}