NoopResponseRouter.cs

using System.Diagnostics.CodeAnalysis;
using System.Threading;
using System.Threading.Tasks;
using MediatR;
using Newtonsoft.Json.Linq;

namespace OmniSharp.Extensions.JsonRpc
{
    /// <summary>
    /// Used top ensure noop behaviors don't throw if they consume a router
    /// </summary>
    internal class NoopResponseRouter : IResponseRouter
    {
        private NoopResponseRouter()
        {
        }

        public static NoopResponseRouter Instance { get; } = new NoopResponseRouter();

        public void SendNotification(string method)
        {
        }

        public void SendNotification<T>(string method, T @params)
        {
        }

        public void SendNotification(IRequest<Unit> request)
        {
        }

        public IResponseRouterReturns SendRequest<T>(string method, T @params)
        {
            return new Impl();
        }

        public IResponseRouterReturns SendRequest(string method)
        {
            return new Impl();
        }

        public Task<TResponse> SendRequest<TResponse>(IRequest<TResponse> request, CancellationToken cancellationToken)
        {
            return Task.FromResult<TResponse>(default!);
        }

        bool IResponseRouter.TryGetRequest(object id, [NotNullWhen(true)] out string? method, [NotNullWhen(true)] out TaskCompletionSource<JToken>? pendingTask)
        {
            method = default!;
            pendingTask = default!;
            return false;
        }

        private class Impl : IResponseRouterReturns
        {
            public Task<TResponse> Returning<TResponse>(CancellationToken cancellationToken)
            {
                return Task.FromResult<TResponse>(default!);
            }

            public Task ReturningVoid(CancellationToken cancellationToken)
            {
                return Task.CompletedTask;
            }
        }
    }
}