|
|
@@ -45,7 +45,8 @@ def read_event(
|
|
|
data = redis_client.xread({channel: x_index}, count=1, block=180_000)
|
|
|
if not data:
|
|
|
return None, None
|
|
|
-
|
|
|
+ print("77777777777777777777777777777777777777777777777777777")
|
|
|
+ print(data)
|
|
|
stream_id = data[0][1][0][0]
|
|
|
event = data[0][1][0][1]
|
|
|
return stream_id, event
|
|
|
@@ -148,8 +149,13 @@ def sub_stream(
|
|
|
break
|
|
|
if not channel_exist(channel):
|
|
|
raise ResourceNotFoundError()
|
|
|
-
|
|
|
+ print(channel)
|
|
|
+ print(x_index)
|
|
|
x_index, data = read_event(channel, x_index)
|
|
|
+ print(
|
|
|
+ "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaassssssssssssssssssssssssssssssssssssss"
|
|
|
+ )
|
|
|
+ print(data)
|
|
|
if not data:
|
|
|
break
|
|
|
|
