Skip to content

Instantly share code, notes, and snippets.

@sergioprates
Created November 18, 2018 12:13
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save sergioprates/25af74b93c99dc5a5f412bd29074692c to your computer and use it in GitHub Desktop.
Save sergioprates/25af74b93c99dc5a5f412bd29074692c to your computer and use it in GitHub Desktop.
Criando uma API Streaming com .NET Core
[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;
var client = new StreamWriter(stream);
_clients.Add(client);
wait.WaitOne();
StreamWriter ignore;
_clients.TryTake(out ignore);
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment