invalid materialized value

[EXTERNAL Wachter Stefan (Keybird IT Consulting und Vetriebs GmbH, INST-ICM/BSV-BS)]

Hi all,

 

the following line of code

 

 

val ((pub, mat), sub) = TestSource.probe[Int].viaMat(Flow[Int])(Keep.both).toMat(TestSink.probe)(Keep.both).run()

 

throws a ClassCastException:

 

 

java.lang.ClassCastException: akka.stream.testkit.TestPublisher$Probe cannot be cast to scala.Tuple2

 

it seems that the viaMat(...)(Keep.both) does not what it promises.

 

Mit freundlichen Grüßen / Best regards

 

Dr. Stefan Wachter

 

Bosch Software Innovations GmbH

Communications (INST-ICM/BSV-BS)

Stuttgarterstr. 130

71332 Waiblingen

GERMANY

www.bosch-si.de

www.blog.bosch-si.com

 

Tel. +49 711 811 58 477

Fax +49 711 811 58 100

external.st...@bosch-si.com

 

[Endre Varga]

Hi Stefan,

What version are you using? This might be a bug.

-Endre

external.stefan.wachter@bosch-si.com

 

--
>>>>>>>>>> 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+unsubscribe@googlegroups.com.
To post to this group, send email to akka...@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

[Endre Varga]

Yes, this is a bug. I filed a ticket: https://github.com/akka/akka/issues/21955

On Tue, Dec 6, 2016 at 10:39 AM, Endre Varga <endre...@lightbend.com> wrote:

Hi Stefan,

What version are you using? This might be a bug.

-Endre