Function first

onchain/eth_helpers.go:33–53

(ctx context.Context, source <-chan interface{})

}

func first(ctx context.Context, source <-chan interface{}) <-chan interface{} {
	out := make(chan interface{})
	go func() {
		defer close(out)
		first := true
		for val := range source {
			if first {
				if val != nil {
					first = false
					select {
					case <-ctx.Done():
						return
					case out <- val:
					}
					return
				}
			}
		}
	}()
	return out
}

func merge(ctx context.Context, cs ...chan interface{}) chan interface{} {
	var wg sync.WaitGroup