Thanks for the help, yes that did the trick to add one more pull for sslIn.
The reason bytesIn is empty is because I really dont need a bidishape. I
need this logic encapsulated in something with one input and two outputs
because after this handshaking is done there is no need to send any more
messages to the TCP socket. However since I found your example the only
example that we close to what i needed and you use bidishape i stick with
this solution until i understad more about Akka Stream.
On Friday, June 2, 2017 at 1:40:42 PM UTC+2, Michał Sitko wrote:
>
> Hey Larsson - based on debug messages when running live I would guess that
> you miss `pull(sslIn)` somewhere. I have a hypothesis for what's going on.
> Let's take a look at:
>
> ```
> setHandler(bytesOut, new OutHandler {
> override def onPull() = state match {
> case Connecting =>
> case Authenticating =>
> case Subscribing =>
> case Subscribed => pull(sslIn)
> }
> })
> ```
>
> You're pulling just when in `Subscribed` state. That means that if
> `bytesOut.onPull` was called before Stage went into `Subscribed` state then
> `pull(sslIn)` will not get called. Therefore we need to ensure that pull
> will be called even in that case. You can do this by e.g. adding:
>
> ```scala
> if (subscriptionValid(event)) {
> state = Subscribed
> logger.info(state.toString)
> if (isAvailable(sslIn)) {
> pull(sslIn)
> }
> }
> ```
>
> in `onPush` handler for `sslIn`.
>
> To debug it I would add `println`s in all places we do `pull(sslIn)` just
> to be sure they're really are executed. In extreme case you can add println
> before all calls to `pull` and `push` - I know there will be a lot of
> output but will give you insight into what's going on.
>
> BTW, I don't understand this one:
>
> ```scala
> setHandler(bytesIn, new InHandler {
> override def onPush() = {
> }
> }
> ```
>
> Also, find it strange that your test works. You are not sending anything
> with `toBetfairProbe` (which simulates input port from TCP as far as I
> understand). I have not idea, maybe you pasted wrong code?
>
> Hope it will help, let us know in case of further troubles.
>
--
>>>>>>>>>> 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 https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
