---- transport::nats::input::test::mock_tests::test_nats_disconnect_stops_delivery stdout ----
--- action 0: StartNats ---
--- action 1: CreateStream ---
2026-06-01T11:09:09.911202Z  INFO async_nats::connector: connected successfully server=43783 max_payload=1048576
2026-06-01T11:09:09.911316Z  INFO async_nats: event: connected
--- action 2: Publish(3) ---
2026-06-01T11:09:09.913362Z  INFO async_nats: event: closed
2026-06-01T11:09:09.917858Z  INFO async_nats::connector: connected successfully server=43783 max_payload=1048576
2026-06-01T11:09:09.917943Z  INFO async_nats: event: connected
--- action 3: CreatePipeline ---
Config:

stream: test_input
transport:
    name: nats_input
    config:
        connection_config:
            server_url: nats://127.0.0.1:43783
        stream_name: str
        consumer_config:
            deliver_policy: All
            filter_subjects: [sub]
format:
    name: json
    config:
        update_format: raw

2026-06-01T11:09:09.920994Z  INFO dbsp_adapters::transport::nats::input: Resume info: Metadata { sequence_numbers: 0..0 }
--- action 4: Extend ---
--- action 5: WaitForRecords(3) ---
2026-06-01T11:09:09.921158Z  INFO async_nats: event: closed
--- action 6: VerifyRecords { output_index: 0, count: 3 } ---
--- action 7: Disconnect ---
--- action 8: Publish(5) ---
2026-06-01T11:09:09.943837Z  INFO async_nats::connector: connected successfully server=43783 max_payload=1048576
2026-06-01T11:09:09.943961Z  INFO async_nats: event: connected
--- action 9: Sleep(500ms) ---
2026-06-01T11:09:09.945904Z  INFO async_nats: event: closed
--- action 10: AssertRecordCount(3) ---

thread 'transport::nats::input::test::mock_tests::test_nats_disconnect_stops_delivery' (23963) panicked at crates/adapters/src/transport/nats/input/test/mock_framework.rs:600:17:
assertion `left == right` failed: AssertRecordCount: expected exactly 3 records, got 8
  left: 8
 right: 3
stack backtrace:
   0: __rustc::rust_begin_unwind
   1: core::panicking::panic_fmt
   2: core::panicking::assert_failed_inner
   3: core::panicking::assert_failed
   4: dbsp_adapters::transport::nats::input::test::mock_framework::NatsMockRunner::exec
   5: dbsp_adapters::transport::nats::input::test::mock_framework::run_nats_mock_test
   6: core::ops::function::FnOnce::call_once
note: Some details are omitted, run with `RUST_BACKTRACE=full` for a verbose backtrace.


failures:
    transport::nats::input::test::mock_tests::test_nats_disconnect_stops_delivery