Method Close

database/binlog/log_stream_event_reader.go:296–306

()

}

func (r *logStreamV4EventReader) Close() error {
	r.isClosed = true

	if r.reader == nil {
		return nil
	}

	err := r.reader.Close()
	r.reader = nil
	return err
}