using System;

using Microsoft.AspNetCore.Mvc;

​

namespace Project.REST.Controllers

{

    [Produces("application/json")]

    public class DefaultController : Controller

    {

        private IConnectionService wsConnection;

​

        public DefaultController(IConnectionService connectionService)

        {

            wsConnection = connectionService;

        }

​

        [Route("api/{path}")]

        [HttpPost]

        public IObservable<Response> Post(string path, [FromBody] Object value)

        {

            return wsConnection.SendRequest(path, value); // This is an RX Subject, guaranteed. It will emit exactly once with an object <Response>.

        }

    }

}

​