Client can't receive back response from server

[Tanimou]

I just tried the function and it appears there's a problem there:
response = await consumer.consume_stream(stream_channel="response_channel",block=0)
the argument "count" is missing

[stephensanwo]

Hi @Tanimou
There is a subtle difference between the StreamConsumer class in the server and worker. While the worker is just waiting to read the next message (ordered queue), by setting count=1, the server is waiting for all messages and iterating over; to then send the response to the appropriate client (multiple clients connected), so we don't need the count argument.
To solve the error you are getting. Use the correct consume_stream methods below:

In server:

async def consume_stream(self, block: int,  stream_channel):
    response = await self.redis_client.xread(
        streams={stream_channel:  '0-0'}, block=block)

    return response

In worker:

async def consume_stream(self, count: int, block: int,  stream_channel):

    response = await self.redis_client.xread(
        streams={stream_channel:  '0-0'}, count=count, block=block)

    return response

Hope this helps.

[Tanimou]

So I rewrote just as what you suggested but still the same problem(see below). I'm getting confused😅

[scott3j]

I am running into the exact same problem. Was this ever solved by change? @Tanimou

[v-prgmr]

@scott3j @Tanimou @stephensanwo
for me everything works as expected while using the same stream consumer in both the server and the worker

[AMAN1620]

Yes its works. You might not be running worker/main.py. that's why its not consuming from message_stream. what you can do is run worker/main.py in other terminal and run server/main.py in other terminal.

I am running into the exact same problem. Was this ever solved by change? @Tanimou