Hi Greg, Try with
.runWith(TestSink.probe[String]) .request(2) .expectNext You should not expect any elements until you have requested for elements. /Patrik On Sat, Oct 24, 2015 at 8:26 PM, tigerfoot <gzol...@gmail.com> wrote: > 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 akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at http://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Patrik Nordwall Typesafe <http://typesafe.com/> - Reactive apps on the JVM Twitter: @patriknw -- >>>>>>>>>> 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 akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
