cocotb_benches.dau_stream_aggregation_tb

Functions

stream_wrapper_emits_sum_metadata(dut)
stream_wrapper_rejects_malformed_descriptor(dut)
_reset(dut) → None
_send_descriptor(dut, opcode, *, row_count, payload_length) → None
_send_value(dut, value) → None
_wait_for_result(dut) → None

Module Contents

async cocotb_benches.dau_stream_aggregation_tb.stream_wrapper_emits_sum_metadata(dut)

async cocotb_benches.dau_stream_aggregation_tb.stream_wrapper_rejects_malformed_descriptor(dut)

async cocotb_benches.dau_stream_aggregation_tb._reset(dut) → None

async cocotb_benches.dau_stream_aggregation_tb._send_descriptor(dut, opcode: dau_core.stream.OperationCode, *, row_count: int, payload_length: int, logical_type: dau_core.stream.LogicalType = LogicalType.INT32) → None

async cocotb_benches.dau_stream_aggregation_tb._send_value(dut, value: int) → None

async cocotb_benches.dau_stream_aggregation_tb._wait_for_result(dut) → None