ReactiveX / RxGo / 774

Committed 24 Mar 2020 05:08PM UTC coverage: 82.944% (+2.5%) from 80.424%

Build # 774

Build Type

push

travis-ci

Committed by

web-flow

Commit Message

Merge pull request #237 from ReactiveX/develop

v2

Run Details

3342 of 3342 new or added lines in 18 files covered. (100.0%)

2772 of 3342 relevant lines covered (82.94%)

1857.95 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

90.0

/iterable_range.go

package rxgo

type rangeIterable struct {
        start, count int
        opts         []Option
}

func newRangeIterable(start, count int, opts ...Option) Iterable {
        return &rangeIterable{
                start: start,
                count: count,
                opts:  opts,
        }
}

func (i *rangeIterable) Observe(opts ...Option) <-chan Item {
        option := parseOptions(append(i.opts, opts...)...)
        ctx := option.buildContext()
        next := option.buildChannel()

        go func() {
                for idx := i.start; idx <= i.start+i.count; idx++ {
                        select {
                        case <-ctx.Done():
                                return
                        case next <- Of(idx):
                        }
                }
                close(next)
        }()
        return next
}

1	package rxgo
2
3	type rangeIterable struct {
4	start, count int
5	opts []Option
6	}
7
8	func newRangeIterable(start, count int, opts ...Option) Iterable {	21✔
9	return &rangeIterable{	21✔
10	start: start,	21✔
11	count: count,	21✔
12	opts: opts,	21✔
13	}	21✔
14	}	21✔
15
16	func (i *rangeIterable) Observe(opts ...Option) <-chan Item {	28✔
17	option := parseOptions(append(i.opts, opts...)...)	28✔
18	ctx := option.buildContext()	28✔
19	next := option.buildChannel()	28✔
20		28✔
21	go func() {	56✔
22	for idx := i.start; idx <= i.start+i.count; idx++ {	160,095✔
23	select {	160,067✔
24	case <-ctx.Done():	×
25	return	×
26	case next <- Of(idx):	160,065✔
27	}
28	}
29	close(next)	26✔
30	}()
31	return next	28✔
32	}

ReactiveX / RxGo / 774

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous