sb_msg = msg_iter._create_stream_beginning_message(stream, ec.id)
ev_msg = msg_iter._create_event_message(ec, stream, 50)
se_msg = msg_iter._create_stream_end_message(stream, iter_id * 193)
sb_msg = msg_iter._create_stream_beginning_message(stream, ec.id)
ev_msg = msg_iter._create_event_message(ec, stream, 50)
se_msg = msg_iter._create_stream_end_message(stream, iter_id * 193)