Skip to content

Instantly share code, notes, and snippets.

@Aankhen
Forked from sheki/abc.scala
Created February 10, 2012 07:31
Show Gist options
  • Save Aankhen/1787419 to your computer and use it in GitHub Desktop.
Save Aankhen/1787419 to your computer and use it in GitHub Desktop.
func() = {
Stream.range(0, noItems) map {
_ => channel.basicGet(queueName, true) match {
case x: GetResponse => Some(x.getBody)
case _ => None
}
} takeWhile (_.isDefined) toList
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment