IBMStreams / streamsx.topology

Develop streaming applications for IBM Streams in Python, Java & Scala.
http://ibmstreams.github.io/streamsx.topology
Apache License 2.0
29 stars 43 forks source link

Python: Provide punct_count() in TopologyTester to test the number of received punctuations #2525

Closed markheger closed 4 years ago

markheger commented 4 years ago

Test that a stream contains a number of window punctuations

tester = Tester(topo)
tester.punct_count(s, expected_punct_count)
tester.test(self.test_ctxtype, cfg)
markheger commented 4 years ago

merged to branch feature/punct