()
| 102 | } |
| 103 | |
| 104 | func (e *ethAdaptor) isConnecting() (result bool) { |
| 105 | if e.ctx == nil { |
| 106 | return |
| 107 | } |
| 108 | select { |
| 109 | case <-e.ctx.Done(): |
| 110 | return |
| 111 | default: |
| 112 | } |
| 113 | for _, ctx := range e.ctxes { |
| 114 | select { |
| 115 | case <-ctx.Done(): |
| 116 | default: |
| 117 | result = true |
| 118 | return |
| 119 | } |
| 120 | } |
| 121 | return |
| 122 | } |
| 123 | |
| 124 | func (e *ethAdaptor) Connect(urls []string, t time.Time) (err error) { |
| 125 | if e.isConnecting() { |
no outgoing calls
no test coverage detected