scala - How do I create an Iteratee in akka?

Question

I have a library that was written in Java that's essentially a pub/sub style queue. The interface is roughly:

class Queue(subscriber: Thing => ()) {
  def publish(thing: Thing) {
  }
}

How do I create an Akka Iteratee that represents the events from a subscriber? i.e. Each time the subscriber function is called, I want the Iteratee object to provide another element.