File tree Expand file tree Collapse file tree 2 files changed +9
-3
lines changed Expand file tree Collapse file tree 2 files changed +9
-3
lines changed Original file line number Diff line number Diff line change 11
11
import tianxiu2b2t .anyio .streams .proxy as streams_proxy
12
12
from tianxiu2b2t .anyio import concurrency
13
13
from tianxiu2b2t .utils import runtime
14
+ from tianxiu2b2t .http .asgi import ASGIApplicationBridge , ASGIConfig
14
15
15
16
from . import utils , abc
16
17
from .logger import logger
@@ -131,9 +132,14 @@ async def serve(
131
132
):
132
133
async with listener :
133
134
logger .tinfo ("web.forward.pub_port" , port = pub_port )
134
- #if not cfg.bridge_web_application:
135
- await listener .serve (pub_handler )
136
- #return
135
+ if not cfg .bridge_web_application :
136
+ await listener .serve (pub_handler )
137
+ async with ASGIApplicationBridge (
138
+ ASGIConfig (
139
+ app ,
140
+ )
141
+ ) as bridge :
142
+ await bridge .serve (listener )
137
143
138
144
async def pub_handler (
139
145
sock : streams .BufferedByteStream ,
You can’t perform that action at this time.
0 commit comments