(err error)
| 256 | } |
| 257 | |
| 258 | func (qe *EvmQueryExecutor) canRetryQueryStream(err error) bool { |
| 259 | if err == nil { |
| 260 | return false |
| 261 | } |
| 262 | |
| 263 | var streamErr *StreamError |
| 264 | if errors.As(err, &streamErr) { |
| 265 | return !streamErr.PageEmitted |
| 266 | } |
| 267 | |
| 268 | return true |
| 269 | } |
| 270 | |
| 271 | func (qe *EvmQueryExecutor) supportsQueryMethods(ups common.Upstream) bool { |
| 272 | client, ok := getGrpcBdsClient(ups) |