Request.Content stream 리디렉션하는 방법

Question

들어오는 HTTP 스트림을 다른 스트림으로 복사하고 대신 사용하려고합니다.

Request.Content.ReadAsStreamAsync().Result을 직접 사용하면 모든 것이 정상적으로 작동합니다.

내가 직면하고있는 문제는 원본 스트림을 다른 스트림으로 "전송"하는 방법입니다. 나는 흐르는 방법을 썼지 만 문제는 모든 스트림 데이터가 도착할 때까지 기다렸거나 (Wait()를 사용할 때) 또는 즉시 반환되고 데이터를 캡처하지 않고 존재한다는 것입니다.

private Task<Stream> GetAudioStream(RecordingSession recordingSession) 
    { 

     Task<Stream> task = Task<Stream>.Factory.StartNew(() => 
     { 
      Request.Content.ReadAsStreamAsync().Result.CopyToAsync(recordingSession.AudioStream).Wait(); 
      return recordingSession.AudioStream; 
     }); 

     return task; 
    } 

Answer 1

아마도 문제는 잘못된 쪽에서 다루어집니다. CopyToAsync은 스트림의 복사본을 제공하며 Task은 모든 데이터가 복사 될 때 CopyToAsync에 의해 반환됩니다.

static async Task<Stream> CopyAndProcessAsync(RecordingSession recordingSession, CancellationToken token) 
{ 
    var srcStream = await Request.Content.ReadAsStreamAsync(); 

    var dstStream = recordingSession.AudioStream; 

    var buffer = new byte[4096]; 
    int bytesRead; 
    while ((bytesRead = await srcStream.ReadAsync(buffer, 0, buffer.Length, token).ConfigureAwait(false)) != 0) 
    { 
     await dstStream.WriteAsync(buffer, 0, bytesRead, token).ConfigureAwait(false); 

     // do whatever you want with the chunk 
     PlaybackChunk(buffer); 
    } 

    return dstStream; 
} 

: 당신이 스트림의 전체 전체 사본이 필요하지 않거나 모든 데이터 기다리지 않으려면

, 다음 자신과 과정 각 청크 수동으로 복사 그렇지 않으면 귀하의 GetAudioStream 결과를 소비하고 싶을 때마다이 작업을 수행하십시오. 각 청크를 처리 할 때 사본이 전혀 필요 없다는 것이 잘 드러날 수 있습니다.

Answer 2

난 당신이 같은 것을 의미 생각 :

private async Task<Stream> GetAudioStream(RecordingSession recordingSession) 
{ 
    var result = await Request.Content.ReadAsStreamAsync(); 
    await result.CopyToAsync(recordingSession.AudioStream); 
    return recordingSession.AudioStream; 
} 

비동기 방법이 작업을 반환합니다. 비동기 메소드가 태스크를 리턴하는 경우는 거의 없습니다.