Added panics instead of print

Infinytum · Jan 15, 2019 · 622d0c3 · 622d0c3
1 parent 1737615
commit 622d0c3
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 8 deletions.
diff --git a/skip.go b/skip.go
@@ -1,7 +1,5 @@
 package reactive
 
-import "fmt"
-
 // Skip will ignore a specified amount of updates
 // and will pass through all following
 func Skip(count int) func(Observable, Subjectable) {
@@ -14,8 +12,9 @@ func Skip(count int) func(Observable, Subjectable) {
 			}
 		})
 
+		// This error will never happen. But for gamma rays sake.
 		if err != nil {
-			fmt.Println(err)
+			panic(err)
 		}
 	}
 }
@@ -33,8 +32,9 @@ func SkipEvery(count int) func(Observable, Subjectable) {
 			}
 		})
 
+		// This error will never happen. But for gamma rays sake.
 		if err != nil {
-			fmt.Println(err)
+			panic(err)
 		}
 	}
 }
diff --git a/take.go b/take.go
@@ -1,7 +1,5 @@
 package reactive
 
-import "fmt"
-
 // Take automatically unsubscribes an observable after
 // the given amount of times it has been updated
 func Take(count int) func(Observable, Subjectable) {
@@ -17,8 +15,9 @@ func Take(count int) func(Observable, Subjectable) {
 			}
 		})
 
+		// This error will never happen. But for gamma rays sake.
 		if err != nil {
-			fmt.Println(err)
+			panic(err)
 		}
 	}
 }
@@ -36,8 +35,9 @@ func TakeEvery(count int) func(Observable, Subjectable) {
 			}
 		})
 
+		// This error will never happen. But for gamma rays sake.
 		if err != nil {
-			fmt.Println(err)
+			panic(err)
 		}
 	}
 }