Method StreamPages

internal/client/client.go:448–486

StreamPages fetches all pages and streams each page's list items via onItems. Returns the last page result (for error checking), whether any list items were found, and any network error. Use this for streaming formats (ndjson, table, csv).

(ctx context.Context, request RawApiRequest, onItems func([]interface{}) error, opts PaginationOptions)

// Returns the last page result (for error checking), whether any list items were found,
// and any network error. Use this for streaming formats (ndjson, table, csv).
func (c *APIClient) StreamPages(ctx context.Context, request RawApiRequest, onItems func([]interface{}) error, opts PaginationOptions) (result interface{}, hasItems bool, err error) {
	totalItems := 0
	results, loopErr := c.paginateLoop(ctx, request, opts, func(r interface{}) error {
		resultMap, ok := r.(map[string]interface{})
		if !ok {
			return nil
		}
		data, ok := resultMap["data"].(map[string]interface{})
		if !ok {
			return nil
		}
		arrayField := output.FindArrayField(data)
		if arrayField == "" {
			return nil
		}
		items, ok := data[arrayField].([]interface{})
		if !ok {
			return nil
		}
		totalItems += len(items)
		if err := onItems(items); err != nil {
			return err
		}
		hasItems = true
		return nil
	})
	if loopErr != nil {
		return nil, false, loopErr
	}

	if hasItems {
		fmt.Fprintf(c.ErrOut, "[pagination] streamed %d pages, %d total items\n", len(results), totalItems)
	}

	if len(results) > 0 {
		return results[len(results)-1], hasItems, nil
	}
	return map[string]interface{}{"code": 0, "msg": "success", "data": map[string]interface{}{}}, false, nil
}

// CheckResponse inspects a Lark API response for business-level errors (non-zero code)
// and routes the result through errclass.BuildAPIError so the wire envelope carries