Hello, I'm trying to run a test of a stream from RabbitMQ like this:
val z = RabbitSource[String]( rc, LateQueue(outQ, durable = true, exclusive = false, autoDelete = false), 1) .map( _.ack ) .runWith(TestSink.probe[String]) .expectSubscription() println(z) I want to pull things off the queue and test them against expected values. (RabbitSource here just creates a stream Source connected to Rabbit bound to a given queue.) Playing around with .expectNext earlier I discovered that rather than starting with pulling my items off the queue as I'd expected, I get a Subscription first. Ok, so I see the .expectSubscription() method in the probe API but it doesn't return Self. Printing the object it seems it is an internal thing: akka.stream.impl.ActorSubscription@7b0044da Not sure what to do with this. What's the best way to probe my stream here? How can I pull items one at a time and check them? Thanks! Greg -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
