How about removing `log_control_iterator` as an argument? (Since `_read_log_control_messages` can call connect directly.)
[ Full content available at: https://github.com/apache/beam/pull/6593 ] This message was relayed via gitbox.apache.org for devnull@infra.apache.org
