Skip unaccessible reddits
This commit is contained in:
parent
ce9fda2b0e
commit
78215d8268
@ -20,6 +20,6 @@ class Reddit {
|
|||||||
|
|
||||||
def fetchSubreddits(subreddits, maxItems = 5) =
|
def fetchSubreddits(subreddits, maxItems = 5) =
|
||||||
stream(subreddits)
|
stream(subreddits)
|
||||||
.flatMap(def(r) = this.fetchSubreddit(r, maxItems))
|
.flatMap(def(r) = try(def() = this.fetchSubreddit(r, maxItems), def(clazz, cause) = []))
|
||||||
.toArray()
|
.toArray()
|
||||||
}
|
}
|
Loading…
Reference in New Issue
Block a user