xljiulang / kestrelapp Goto Github PK

public override async Task OnConnectedAsync(ConnectionContext connection)
{
    var input = connection.Transport.Input;
    try
    {
	    while (true)
	    {
		    var result = await input.ReadAsync(connection.ConnectionClosed);
		    if (result.IsCanceled) { break; }
		    var buffer = result.Buffer;
		    logger.LogInformation($"read buffer of length {buffer.Length}");
		    foreach (var mem in buffer)
		    {
			    await connection.Transport.Output.WriteAsync(mem);
		    }
		    input.AdvanceTo(buffer.End);
	    }
    }
    catch(Exception e)
    {
	    logger.LogInformation(e, "some exception");
    }
}