# are not at the same time. This test is targetting event message.
sb_msg = msg_iter._create_stream_beginning_message(stream, ec.id)
ev_msg = msg_iter._create_event_message(ec, stream, 50)
# are not at the same time. This test is targetting event message.
sb_msg = msg_iter._create_stream_beginning_message(stream, ec.id)
ev_msg = msg_iter._create_event_message(ec, stream, 50)