sergioprates

using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Net.Http.Headers;
using System;
using System.IO;
using System.Threading;
using System.Threading.Tasks;

namespace DotNetCoreStreaming.Results
{

sergioprates

using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Hosting;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.DependencyInjection;

namespace DotNetCoreStreaming
{
    public class Startup
    {
        public void ConfigureServices(IServiceCollection services)

sergioprates

namespace DotNetCoreStreaming.Enums
{
    public enum EventoEnum
    {
        Insert = 1,
        Update = 2
    }
}

sergioprates

namespace DotNetCoreStreaming.Models
{
    public class Cliente
    {
        public long Id { get; set; }

        public string Nome { get; set; }
    }
}

sergioprates

private static ConcurrentBag<StreamWriter> _clients;

static ClienteController()
{
    _clients = new ConcurrentBag<StreamWriter>();
}

sergioprates

[HttpPost]
public IActionResult Post(Cliente cliente)
{
    //Fazer o Insert
    EnviarEvento(cliente, EventoEnum.Insert);
    return Ok();
}

[HttpPut]
public IActionResult Put(Cliente cliente)

sergioprates

[HttpGet]
[Route("Streaming")]
public IActionResult Stream()
{
    return new PushStreamResult(OnStreamAvailable, "text/event-stream", HttpContext.RequestAborted);
}

private void OnStreamAvailable(Stream stream, CancellationToken requestAborted)
{
    var wait = requestAborted.WaitHandle;

sergioprates

using DotNetCoreStreaming.Enums;
using DotNetCoreStreaming.Models;
using DotNetCoreStreaming.Results;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Newtonsoft.Json;
using System.Collections.Concurrent;
using System.IO;
using System.Threading;
using System.Threading.Tasks;

sergioprates

print('Hello World!')

sergioprates

vetor <- c(1, 5, 4)
vetor
# SAÍDA: 1 5 4