A Flow is a graph with 1 input and 1 output, you are connecting the
bidiflow (2 inputs and 2 outputs) to eachother, leaving no inputs nor
outputs open, which means it cannot be a Flow.
On Mon, Jul 20, 2015 at 2:58 PM, Thomas Zimmer <t.zim...@eslgaming.com>
wrote:
> Hey,
>
> I really have problems understanding the TLS Bidi-Flows. The specs are not
> very helpful as they only do "echo" the input as fas as I understood and
> there is not official documentation. What I have so far:
>
> * A TCP flow (Flow[ByteString, ByteString])
> * A logical flow (Flow[ByteString, ByteString])
>
> How can i connect this to the TLS Bidi-Flow. Here is the code I tried:
>
> val session =
> NegotiateNewSession.withDefaults.withCipherSuites("TLS_RSA_WITH_AES_128_CBC_SHA")
>
>
> .withCipherSuites("TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA256","TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA",
>
> "TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384","TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA",
> "TLS_DHE_RSA_WITH_AES_256_CBC_SHA",
> "TLS_DHE_RSA_WITH_AES_128_CBC_SHA","TLS_RSA_WITH_AES_128_CBC_SHA256","TLS_RSA_WITH_AES_128_CBC_SHA",
> "TLS_RSA_WITH_AES_256_CBC_SHA256", "TLS_RSA_WITH_AES_256_CBC_SHA")
> .withProtocols("TLSv1.2")
> .withClientAuth(ClientAuth.None)
>
>
> val closing = IgnoreComplete
> val tlsHandler = SslTls(sslContext, session, akka.stream.io.Role.server,
> closing)
> val logicalFlow = getLogicalFlow
>
> // SslTlsInbound to bytes
> val inboundFlow: Flow[SslTlsInbound, ByteString, Unit] =
> Flow[SslTlsInbound].map {
> case SessionBytes(_, bytes: ByteString) =>
> log.info("Received bytes")
> bytes
> case SessionTruncated => sys.error("Truncated")
> }
>
> // bytes to SslTlsOutbound
> val outboundFlow: Flow[ByteString, SslTlsOutbound, Unit] =
> Flow[ByteString].map {
> case bytes: ByteString =>
> log.info("Sending bytes")
> SendBytes(bytes)
> }
>
> val tlsFlow = Flow() { implicit builder =>
> import FlowGraph.Implicits._
>
> val tls = builder.add(tlsHandler)
>
> // Define outbound/inbound flows
> tls.out2 ~> inboundFlow ~> tls.in2
> // tls.out1 ~> outboundFlow ~> tls.in1
> tls.in1 <~ outboundFlow <~ tls.out1
>
> // Define in/outlet
> (tls.in2, tls.out1)
> }
>
>
> // conn = Tcp.IncomingConnection
>
> conn.handleWith(tlsFlow)
>
>
>
> As soon as I start the application I get this error-message:
>
>
> Cannot build Flow with open inputs () and outputs ()
> info] akka.actor.ActorInitializationException: exception during creation
> info] at akka.actor.ActorInitializationException$.apply(Actor.scala:166)
> info] at akka.actor.ActorCell.create(ActorCell.scala:596)
> info] at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:456)
> info] at akka.actor.ActorCell.systemInvoke(ActorCell.scala:478)
> info] at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:263)
> info] at akka.dispatch.Mailbox.run(Mailbox.scala:219)
> info] at
> akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:397)
> info] at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
> info] at
> scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
> info] at
> scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
> info] at
> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
> info] Caused by: java.lang.IllegalArgumentException: Cannot build Flow with
> open inputs () and outputs ()
> info] at akka.stream.scaladsl.FlowGraph$Builder.buildFlow(Graph.scala:427)
> info] at akka.stream.scaladsl.FlowApply$class.apply(FlowApply.scala:18)
> info] at akka.stream.scaladsl.Flow$.apply(Flow.scala:313)
>
>
> I do not understand where I should have open inputs or outputs? All the
> BIDI-Flow inputs should be in use?
>
> --
> >>>>>>>>>> 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.
>
--
Cheers,
√
--
>>>>>>>>>> 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.
