Skip to content
Merged
6 changes: 3 additions & 3 deletions bottlecap/src/extension/telemetry/listener.rs
Original file line number Diff line number Diff line change
Expand Up @@ -124,9 +124,9 @@ impl TelemetryListener {

let mut telemetry_events: Vec<TelemetryEvent> = match serde_json::from_slice(&body) {
Ok(events) => events,
// The Telemetry API splits an oversized record across two POSTs, and neither half
// parses alone. See `stitch`.
Err(e) => match state.fragments.stitch(&body, &e) {
// Lambda cuts a long log line into pieces, and a payload that holds a piece does not
// parse. See `stitch`.
Err(e) => match state.fragments.stitch(&body) {
Stitch::Complete(events) => {
debug!(
"TELEMETRY API | Reassembled a split payload, recovered {} events",
Expand Down
Loading
Loading