Merge branch 'dev'

TakayukiCho · Mar 18, 2017 · d71048c · d71048c
2 parents a484142 + 0892a68
commit d71048c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/observable/observable.go b/observable/observable.go
@@ -300,7 +300,7 @@ func Empty() Observable {
 
 // Interval creates an Observable emitting incremental integers infinitely between
 // each given time interval.
-func Interval(term chan struct{}, timeout time.Duration) Observable {
+func Interval(term chan struct{}, interval time.Duration) Observable {
 	source := make(chan interface{})
 	go func(term chan struct{}) {
 		i := 0
@@ -309,7 +309,7 @@ func Interval(term chan struct{}, timeout time.Duration) Observable {
 			select {
 			case <-term:
 				break OuterLoop
-			case <-time.After(timeout):
+			case <-time.After(interval):
 				source <- i
 			}
 			i++