System.ClientModel.AsyncStreamingClientResult
Creates asynchronous streaming results for established service responses.
public static AsyncStreamingClientResult<T> Create<T>(PipelineResponse response, Func<Stream, CancellationToken, IAsyncEnumerable<T>> producer, CancellationToken operationCancellationToken = default)
Creates a result whose values are produced from the response content stream.
public static AsyncStreamingClientResult<T> CreateJsonLines<T>(PipelineResponse response, Func<BinaryData, T> itemParser, CancellationToken operationCancellationToken = default)
Creates a result that parses newline-delimited JSON values.
public static AsyncStreamingClientResult<BinaryData> CreateJsonLines(PipelineResponse response, CancellationToken operationCancellationToken = default)
Creates a result that parses raw newline-delimited JSON values.
public static AsyncStreamingClientResult<SseItem<T>> CreateSse<T>(PipelineResponse response, SseItemParser<T> itemParser, Func<SseItem<BinaryData>, bool> isTerminal = null, CancellationToken operationCancellationToken = default)
Creates a result that parses server-sent events.
public static AsyncStreamingClientResult<SseItem<BinaryData>> CreateSse(PipelineResponse response, Func<SseItem<BinaryData>, bool> isTerminal = null, CancellationToken operationCancellationToken = default)
Creates a result that parses raw server-sent events.