File tree Expand file tree Collapse file tree 1 file changed +0
-11
lines changed Expand file tree Collapse file tree 1 file changed +0
-11
lines changed Original file line number Diff line number Diff line change @@ -31,17 +31,6 @@ pub(crate) async fn rewrite_html_stream<R>(
31
31
where
32
32
R : AsyncRead + Unpin + ' static ,
33
33
{
34
- // TODO:
35
- // - create a background normal thread for the rewriter
36
- // - perhaps use render_in_threadpool? then the CPU usage is also possible to limit?
37
- // - can receive chunks of input data with channel 1
38
- // - can transfer back chunks of response data on channel 2
39
- // - perhaps channel 3 as one-shot to finish / exit? or is it enough to send zero bytes on
40
- // channel 1? if we use render_in_threadpool, this is solved.
41
- // then
42
- // the async stream can read and yield from the channels
43
- //
44
-
45
34
stream ! ( {
46
35
let ( data_sender, data_receiver) = std:: sync:: mpsc:: channel:: <Option <Vec <u8 >>>( ) ;
47
36
let ( result_sender, mut result_receiver) = tokio:: sync:: mpsc:: unbounded_channel:: <Bytes >( ) ;
You can’t perform that action at this time.
0 commit comments