We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c326112 commit d5e518cCopy full SHA for d5e518c
2 files changed
core/web.py
@@ -11,6 +11,7 @@
11
import tianxiu2b2t.anyio.streams.proxy as streams_proxy
12
from tianxiu2b2t.anyio import concurrency
13
from tianxiu2b2t.utils import runtime
14
+from tianxiu2b2t.http.asgi import ASGIApplicationBridge, ASGIConfig
15
16
from . import utils, abc
17
from .logger import logger
@@ -131,9 +132,14 @@ async def serve(
131
132
):
133
async with listener:
134
logger.tinfo("web.forward.pub_port", port=pub_port)
- #if not cfg.bridge_web_application:
135
- await listener.serve(pub_handler)
136
- #return
+ if not cfg.bridge_web_application:
+ await listener.serve(pub_handler)
137
+ async with ASGIApplicationBridge(
138
+ ASGIConfig(
139
+ app,
140
+ )
141
+ ) as bridge:
142
+ await bridge.serve(listener)
143
144
async def pub_handler(
145
sock: streams.BufferedByteStream,
requirements.txt
0 Bytes
0 commit comments