MCPcopy Index your code
hub / github.com/pathwaycom/pathway / assert_stream_equal

Function assert_stream_equal

python/pathway/tests/utils.py:300–302  ·  view source on GitHub ↗
(expected: list[DiffEntry], table: pw.Table)

Source from the content-addressed store, hash-verified

298
299
300def assert_stream_equal(expected: list[DiffEntry], table: pw.Table):
301 callback = CheckStreamEntriesEqualityCallback(expected)
302 pw.io.subscribe(table, callback, callback.on_end)
303
304
305def assert_equal_tables(

Callers 2

test_exactly_onceFunction · 0.90
test_exactly_once_from_behaviorFunction · 0.90

Calls 2

CheckStreamEntriesEqualityCallbackClass · 0.85
subscribeMethod · 0.80

Tested by 2

test_exactly_onceFunction · 0.72
test_exactly_once_from_behaviorFunction · 0.72