I opened a ticket to make sure the error is signalled properly in this situation: https://github.com/akka/akka/issues/18486
-- Cheers, Konrad `ktoso` Malawski Akka @ Typesafe On 16 September 2015 at 12:39:47, Endre Varga ([email protected]) wrote: Hi, It is invalid to attach two publishers to the same subscriber (RS specificatin does not allow this). It is strange that it does not fail explicitly though, that is probably a bug. -Endre On Wed, Sep 16, 2015 at 12:35 PM, anil chalil <[email protected]> wrote: Hi everybody object Main2 extends App{ implicit val system = ActorSystem("streamakka") implicit val materializer = ActorMaterializer() val sub1=Source.subscriber[String].to(Sink.foreach(println)).run() val pub1=Source.repeat("p1").runWith(Sink.publisher) val pub2=Source.repeat("p2").runWith(Sink.publisher) pub1.subscribe(sub1) pub2.subscribe(sub1) } I just wrote simple code. There are two publishers and one subscriber. I am using reactive stream api because in my app i want to dynamically subscriber client connections(Publishers) to a single subscriber(actually a flow implemented with akka stream again). In my machine sometimes it just write p1 p1 p1 p1 or p2 p2 p2 p2 sometimes it just writes lots of p1 or p2 values. Am i missing something? -- >>>>>>>>>> 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. -- >>>>>>>>>> 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. -- >>>>>>>>>> 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.
