()
| 226 | thread_send_queue.put(value) |
| 227 | |
| 228 | async def main() -> None: |
| 229 | search = request.query_string.decode() |
| 230 | await serve_layout( |
| 231 | reactpy.Layout( |
| 232 | ConnectionContext( |
| 233 | component, |
| 234 | value=Connection( |
| 235 | scope=request.environ, |
| 236 | location=Location( |
| 237 | pathname=f"/{path}", |
| 238 | search=f"?{search}" if search else "", |
| 239 | ), |
| 240 | carrier=_FlaskCarrier(request, websocket), |
| 241 | ), |
| 242 | ), |
| 243 | ), |
| 244 | send_coro, |
| 245 | async_recv_queue.get, |
| 246 | ) |
| 247 | |
| 248 | main_future = asyncio.ensure_future(main(), loop=loop) |
| 249 |
no test coverage detected