Summary
pause_stream() emits:
env.events().publish((Symbol::new(&env, "stream_paused"),), (stream_id,));
resume_stream() emits:
env.events().publish((Symbol::new(&env, "stream_resumed"),), (stream_id,));
There are no tests verifying these events are emitted at all or that the stream_id in the payload is correct. The existing pause/resume tests only check StreamStatus fields.
Tasks
Labels: testing, forge-stream
Summary
pause_stream()emits:resume_stream()emits:There are no tests verifying these events are emitted at all or that the
stream_idin the payload is correct. The existing pause/resume tests only checkStreamStatusfields.Tasks
pause_stream(), useenv.events().all()to assert astream_pausedevent existsstream_idresume_stream(), assert astream_resumedevent exists with the correctstream_idpause_stream()call (e.g. already paused)test_submit_price_emits_eventinforge-oracleLabels:
testing,forge-stream