Skip to content

Commit cf685dd

Browse files
committed
fix(fanout): Remove release_build variant of test
1 parent 44699fa commit cf685dd

1 file changed

Lines changed: 0 additions & 21 deletions

File tree

lib/vector-core/src/fanout.rs

Lines changed: 0 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -867,28 +867,7 @@ mod tests {
867867
.expect("should not fail");
868868
}
869869

870-
// The empty-batch guard panics via `debug_assert!` in debug builds and silently drops in
871-
// release builds. The two tests below cover each half of that behavior.
872870
#[tokio::test]
873-
async fn fanout_drops_empty_event_array_in_release_builds() {
874-
let (mut fanout, _, receivers) = fanout_from_senders(&[2, 2]);
875-
let empty: EventArray = Vec::<LogEvent>::new().into();
876-
877-
fanout
878-
.send(empty, None)
879-
.await
880-
.expect("empty batch should be dropped, not errored");
881-
882-
for receiver in receivers {
883-
assert!(
884-
collect_ready(receiver.into_stream()).is_empty(),
885-
"no downstream receiver should observe the empty batch",
886-
);
887-
}
888-
}
889-
890-
#[tokio::test]
891-
#[cfg(debug_assertions)]
892871
#[should_panic(expected = "Fanout received empty event batch from upstream component")]
893872
async fn fanout_panics_on_empty_event_array_in_debug_builds() {
894873
let (mut fanout, _, _receivers) = fanout_from_senders(&[2, 2]);

0 commit comments

Comments
 (0)