@@ -205,7 +205,7 @@ private async Task InnerOnConnectionAsync(ConnectionContext context)
205205 (
206206 pool : memoryPoolFeature . MemoryPool ,
207207 readerScheduler : _options . Scheduler ,
208- writerScheduler : PipeScheduler . Inline ,
208+ writerScheduler : _options . Scheduler ,
209209 pauseWriterThreshold : _options . MaxInputBufferSize ?? 0 ,
210210 resumeWriterThreshold : _options . MaxInputBufferSize / 2 ?? 0 ,
211211 useSynchronizationContext : false ,
@@ -215,8 +215,8 @@ private async Task InnerOnConnectionAsync(ConnectionContext context)
215215 var outputPipeOptions = new PipeOptions
216216 (
217217 pool : memoryPoolFeature . MemoryPool ,
218- readerScheduler : PipeScheduler . Inline ,
219- writerScheduler : PipeScheduler . Inline ,
218+ readerScheduler : _options . Scheduler ,
219+ writerScheduler : _options . Scheduler ,
220220 pauseWriterThreshold : _options . MaxOutputBufferSize ?? 0 ,
221221 resumeWriterThreshold : _options . MaxOutputBufferSize / 2 ?? 0 ,
222222 useSynchronizationContext : false ,
0 commit comments