@ -209,6 +209,13 @@ async def stream_wrapper(request):
)
@app.route("/readyz")
async def ready_check(request):
if len(app.ctx.frames) == 2 ** SLIDE_WINDOW:
return response.text("OK")
return response.text("Not enough frames", status=503)
@app.route('/event')
async def wrapper_stream_event(request):
async def stream_event(response):