system.reactive Getting started with system.reactive Subscribing to an observable (CancellationToken)

Example

emails.Subscribe(email =>
    Console.WriteLine("Email from {0} to {1}", email.From, email.To),
    cancellationToken);