Android Question AsyncStreams

[Ale_resource]

Hi I have a connection to a device in tcp to which I send a command and then I get a response.
I send the command like this:

AStreams1.Write2(b,0,b.Length)

and then I wait for the answer like this:

Wait For AStreams1_NewData(BufferProg() As Byte)
Dim Text As String = BytesToString(BufferProg, 0, BufferProg.Length, "UTF8").Trim

the problem is that I never get the full answer and I can't understand why.
This is the answer I get from the code above :

V000000000000000000000000000000000000000000000
V001000000000000000000000000000000000000000000
V002040000000000000000000000000000000000000000

While in reality it should be this:

V000000000000000000000000000000000000000000000
V001000000000000000000000000000000000000000000
V002040000000000000000000000000000000000000000
V003000000000000000000000000000000000000000000
V004000000000000000000000000000000000000000000
V005000000000000000000000000000000000000000000
V006000000000000000000000000000000000000000000
V007000000000000000000000000000000000000000000
V008000110000000000000000000000000000000000000
V009000210000000000000000000000000000000000000
V010000310000000000000000000000000000000000000
V011000510000000000000000000000000000000000000
V012000610000000000000000000000000000000000000
V013000000000000000000000000000000000000000000
V014000000000000000000000000000000000000000000
V015000000000000000000000000000000000000000000
V016000000000000000000000000000000000000000000
V017000000000000000000000000000000000000000000
V018000000000000000000000000000000000000000000
V019000000000000000000000000000000000000000000
V020000000000000000000000000000000000000000000
V021000000000000000000000000000000000000000000
V022000000000000000000000000000000000000000000
V023000000000000000000000000000000000000000000
V024000000000000000000000000000000000000000000
V025000000000000000000000000000000000000000000
V026000000000000000000000000000000000000000000
V027000000000000000000000000000000000000000000
V028000000000000000000000000000000000000000000
V029000000000000000000000000000000000000000000
V030000000000000000000000000000000000000000000
V031000000000000000000000000000000000000000000
V032000000000000000000000000000000000000000000
V033000000000000000000000000000000000000000000
V034000000000000000000000000000000000000000000
V035000000000000000000000000000000000000000000
V036000000000000000000000000000000000000000000
V037000000000000000000000000000000000000000000
V038000000000000000000000000000000000000000000
V039000000000000000000000000000000000000000000

It seems that reception is interrupted or I don't know what else , thanks

 

[KMatle]

Did you initialize with prefix mode?

 

[Ale_resource]

Did you initialize with prefix mode?

no because the other device does not support prefix mode

 

[DonManfred]

Note that you should expect the packets to be splittet. Not all data can come in one event...

 

[Ale_resource]

Note that you should expect the packets to be splittet. Not all data can come in one event...

I put the log write in the newdata event and it is written only once

 

[Erel]

Your code will only handle the NewData event once. Don't use Wait For here. Implement it in a different sub.

 

[Ale_resource]

Your code will only handle the NewData event once. Don't use Wait For here. Implement it in a different sub.

I tried to put the following code twice:

Wait For AStreams1_NewData(BufferProg() As Byte)
Wait For AStreams1_NewData(BufferProg() As Byte)

but doing so does not execute subsequent lines of code. So I figured the package is sent all at once.
Isn't there some time or byte limitation?

 

[Erel]

This code is plainly wrong. You cannot assume the number of times that it will be called in non-prefix mode.

First step is to implement the event in its own sub.

 

[Ale_resource]

This code is plainly wrong. You cannot assume the number of times that it will be called in non-prefix mode.

First step is to implement the event in its own sub.

How should I do it then? Making a loop from 1 to 100 for example and putting inside the call to the new_data?
Can you give me an example? thank you

 

[Erel]

Sub AStreams1_NewData(BufferProg() As Byte)
 Log(BufferProg.Length)
End Sub

Delete the Wait For AStream1...

 

[Ale_resource]

Sub AStreams1_NewData(BufferProg() As Byte)
Log(BufferProg.Length)
End Sub

Delete the Wait For AStream1...

I did so

....
AStreams1.Write2(b,0,b.Length)
....

Sub AStreams1_NewData (Buffer() As Byte)
    Log(Buffer.Length)
End Sub

but on the log I don't see anything

 

[Erel]

There nothing more that I can say based on the information you provided.

 

[Ale_resource]

There nothing more that I can say based on the information you provided.

I upload a small sample project of the code I use, maybe something wrong?

 

[Erel]

1. Switch to B4XPages. This is especially important when dealing with communication.
2. Remove HttpUtils2 and add OkHttpUtils2.
3. Please read my short answers more carefully:

 

[Ale_resource]

1. Switch to B4XPages. This is especially important when dealing with communication.
2. Remove HttpUtils2 and add OkHttpUtils2.
3. Please read my short answers more carefully:

View attachment 111510

Yes, the changes you indicated to me I made in the original project but not in the demo that I sent you sorry ... all done except the transition to B4XPages
but unfortunately the result does not change

 

[Chris2]

As well as @Erel's points, I think you may have missed @DonManfred 's...

Note that you should expect the packets to be splittet. Not all data can come in one event...

The reply you're expecting will come in bits, so you might need to let it build up...

Private sb As StringBuilder        <--- in Globals

Sub AStreams1_NewData (Buffer() As Byte)
    sb.Append(BytesToString(BufferProg, 0, BufferProg.Length, "UTF8")
    Dim s as string = sb.ToString
    Log(s)
    ....
    ....
End Sub

You can then check if string s has the complete message using regex, or its length, or whatever.
You will need to know something about the reply you're expecting though in order to know when it is complete.

AsyncStreamsText might be useful also....

[class] AsyncStreamsText - Useful when working with streams of text

When a message (set of bytes) is sent over a network channel, of any type, there is no guarantee that the whole message will arrive as a single set of bytes. The message might be split or merged together with other messages. One way to overcome this issue is to initialize AsyncStreams in...

www.b4x.com