Method SubscribeEvent

onchain/eth_subscribe.go:103–140

SubscribeEvent is a log subscription operation

(subscribeTypes []int)

// SubscribeEvent is a log subscription operation
func (e *ethAdaptor) SubscribeEvent(subscribeTypes []int) (chan interface{}, chan error) {
	var eventList []chan interface{}
	var errcs []chan error
	for _, subscribeType := range subscribeTypes {
		if subscribeType >= SubscribeCommitrevealLogStartCommitreveal {
			for i := 0; i < len(e.crs); i++ {
				if e.crs[i] == nil ||
					e.ctxes[i] == nil {
					continue
				}
				select {
				case <-e.ctxes[i].Done():
					continue
				default:
				}
				out, errc := crTable[subscribeType](e.ctxes[i], e.crs[i])
				eventList = append(eventList, out)
				errcs = append(errcs, errc)
			}
		} else {
			for i := 0; i < len(e.proxies); i++ {
				if e.proxies[i] == nil ||
					e.ctxes[i] == nil {
					continue
				}
				select {
				case <-e.ctxes[i].Done():
					continue
				default:
				}
				out, errc := proxyTable[subscribeType](e.ctxes[i], e.proxies[i])
				eventList = append(eventList, out)
				errcs = append(errcs, errc)
			}
		}
	}
	return firstEvent(e.ctx, merge(e.ctx, eventList...)), mergeError(e.ctx, errcs...)
}

func getIndex(ctx context.Context) (idx int) {
	if v := ctx.Value("index"); v != nil {