using System;

using System.Net;

using System.Threading;

using System.Threading.Tasks;

using RtspClientSharp;

using RtspClientSharp.Rtsp;

namespace SimpleRtspClient

{

class Program

{

static void Main()

{

var serverUri = new Uri("rtsp://192.168.1.77:554/ucast/11");

var credentials = new NetworkCredential("admin", "123456");

var connectionParameters = new ConnectionParameters(serverUri, credentials);

var cancellationTokenSource = new CancellationTokenSource();

Task connectTask = ConnectAsync(connectionParameters, cancellationTokenSource.Token);

Console.WriteLine("Press any key to cancel");

Console.ReadLine();

cancellationTokenSource.Cancel();

Console.WriteLine("Canceling");

connectTask.Wait(CancellationToken.None);

}

private static async Task ConnectAsync(ConnectionParameters connectionParameters, CancellationToken token)

{

try

{

TimeSpan delay = TimeSpan.FromSeconds(5);

using (var rtspClient = new RtspClient(connectionParameters))

{

rtspClient.FrameReceived +=

(sender, frame) => Console.WriteLine($"New frame {frame.Timestamp}: {frame.GetType().Name}");

while (true)

{

Console.WriteLine("Connecting...");

try

{

await rtspClient.ConnectAsync(token);

}

catch (OperationCanceledException)

{

return;

}

catch (RtspClientException e)

{

Console.WriteLine(e.ToString());

await Task.Delay(delay, token);

continue;

}

Console.WriteLine("Connected.");

try

{

await rtspClient.ReceiveAsync(token);

}

catch (OperationCanceledException)

{

return;

}

catch (RtspClientException e)

{

Console.WriteLine(e.ToString());

await Task.Delay(delay, token);

}

}

}

}

catch (OperationCanceledException)

{

}

}

}

}