in elastic_transport/_serializer.py [0:0]
def loads(self, data: bytes) -> Any:
ndjson = []
for line in re.split(b"[\n\r]", data):
if not line:
continue
try:
ndjson.append(self.json_loads(line))
except (ValueError, TypeError) as e:
raise SerializationError(
message=f"Unable to deserialize as NDJSON: {data!r}", errors=(e,)
)
return ndjson