()
| 219 | } |
| 220 | |
| 221 | func (w *PollingClient) reqPoll() { |
| 222 | // non-blocking send |
| 223 | select { |
| 224 | case w.pollReqCh <- struct{}{}: |
| 225 | default: |
| 226 | } |
| 227 | } |
| 228 | |
| 229 | func (w *PollingClient) FilterLogsByBlockRange(start *big.Int, end *big.Int, eventSig string) ([]types.Log, error) { |
| 230 | topic := crypto.Keccak256Hash([]byte(eventSig)) |