Internalize Microsoft.AspNetCore.Http.Connections.Client.Internal (#2014)
This commit is contained in:
parent
021356bf27
commit
d0137a996c
|
|
@ -9,7 +9,7 @@ using System.Threading.Tasks;
|
||||||
|
|
||||||
namespace Microsoft.AspNetCore.Http.Connections.Client.Internal
|
namespace Microsoft.AspNetCore.Http.Connections.Client.Internal
|
||||||
{
|
{
|
||||||
public class AccessTokenHttpMessageHandler : DelegatingHandler
|
internal class AccessTokenHttpMessageHandler : DelegatingHandler
|
||||||
{
|
{
|
||||||
private readonly Func<Task<string>> _accessTokenProvider;
|
private readonly Func<Task<string>> _accessTokenProvider;
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -5,7 +5,7 @@ using System.IO.Pipelines;
|
||||||
|
|
||||||
namespace Microsoft.AspNetCore.Http.Connections.Client.Internal
|
namespace Microsoft.AspNetCore.Http.Connections.Client.Internal
|
||||||
{
|
{
|
||||||
public static class ClientPipeOptions
|
internal static class ClientPipeOptions
|
||||||
{
|
{
|
||||||
public static PipeOptions DefaultOptions = new PipeOptions(writerScheduler: PipeScheduler.ThreadPool, readerScheduler: PipeScheduler.ThreadPool, useSynchronizationContext: false, pauseWriterThreshold: 0, resumeWriterThreshold: 0);
|
public static PipeOptions DefaultOptions = new PipeOptions(writerScheduler: PipeScheduler.ThreadPool, readerScheduler: PipeScheduler.ThreadPool, useSynchronizationContext: false, pauseWriterThreshold: 0, resumeWriterThreshold: 0);
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -10,7 +10,7 @@ using Microsoft.Extensions.Logging;
|
||||||
|
|
||||||
namespace Microsoft.AspNetCore.Http.Connections.Client.Internal
|
namespace Microsoft.AspNetCore.Http.Connections.Client.Internal
|
||||||
{
|
{
|
||||||
public class LoggingHttpMessageHandler : DelegatingHandler
|
internal class LoggingHttpMessageHandler : DelegatingHandler
|
||||||
{
|
{
|
||||||
private readonly ILogger<LoggingHttpMessageHandler> _logger;
|
private readonly ILogger<LoggingHttpMessageHandler> _logger;
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -24,7 +24,7 @@ namespace Microsoft.AspNetCore.Http.Connections.Client.Internal
|
||||||
|
|
||||||
private readonly CancellationTokenSource _transportCts = new CancellationTokenSource();
|
private readonly CancellationTokenSource _transportCts = new CancellationTokenSource();
|
||||||
|
|
||||||
public Task Running { get; private set; } = Task.CompletedTask;
|
internal Task Running { get; private set; } = Task.CompletedTask;
|
||||||
|
|
||||||
public PipeReader Input => _transport.Input;
|
public PipeReader Input => _transport.Input;
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -25,7 +25,7 @@ namespace Microsoft.AspNetCore.Http.Connections.Client.Internal
|
||||||
private IDuplexPipe _transport;
|
private IDuplexPipe _transport;
|
||||||
private IDuplexPipe _application;
|
private IDuplexPipe _application;
|
||||||
|
|
||||||
public Task Running { get; private set; } = Task.CompletedTask;
|
internal Task Running { get; private set; } = Task.CompletedTask;
|
||||||
|
|
||||||
public PipeReader Input => _transport.Input;
|
public PipeReader Input => _transport.Input;
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -26,7 +26,7 @@ namespace Microsoft.AspNetCore.Http.Connections.Client.Internal
|
||||||
|
|
||||||
private IDuplexPipe _transport;
|
private IDuplexPipe _transport;
|
||||||
|
|
||||||
public Task Running { get; private set; } = Task.CompletedTask;
|
internal Task Running { get; private set; } = Task.CompletedTask;
|
||||||
|
|
||||||
public PipeReader Input => _transport.Input;
|
public PipeReader Input => _transport.Input;
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue