ProgressNotifications.cs

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Threading.Tasks;
using NUnit.Framework;
using Realms;
using Realms.Sync;

namespace Examples
{
    public class ProgressNotifications
    {
        App app;
        Realms.Sync.User user;
        PartitionSyncConfiguration config;
        string myRealmAppId = Config.AppId;

        public class ProgressObj : RealmObject
        {
            [PrimaryKey]
            [MapTo("_id")]
            public int Id { get; set; }
            public string Name { get; set; }
        }

        [Test]
        public async Task TestWaitForChangesToDownloadAsync()
        {
            var appConfig = new AppConfiguration(myRealmAppId)
            {
                DefaultRequestTimeout = TimeSpan.FromMilliseconds(1500)
            };
            app = App.Create(appConfig);
            user = app.LogInAsync(Credentials.Anonymous()).Result;
            config = new PartitionSyncConfiguration("myPartition", user);
            try
            {
                // :snippet-start: wait-for-changes-to-download-async-progress-notification
                // :uncomment-start:
                // using Realms.Sync;

                // :uncomment-end:
                var realm = Realm.GetInstance(config);
                await realm.SyncSession.WaitForDownloadAsync();
                // :snippet-end:
                realm.Dispose();
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
        }
        [Test]
        public void TestUploadDownloadProgressNotification()
        {
            //var progressNotificationTriggered = false;
            var appConfig = new AppConfiguration(myRealmAppId)
            {
                DefaultRequestTimeout = TimeSpan.FromMilliseconds(1500)
            };
            app = App.Create(appConfig);
            user = app.LogInAsync(Credentials.Anonymous()).Result;
            config = new PartitionSyncConfiguration("myPartition", user);
            var realm = Realm.GetInstance(config);
            // :snippet-start: upload-download-progress-notification
            var session = realm.SyncSession;
            var token = session.GetProgressObservable(ProgressDirection.Upload,
                ProgressMode.ReportIndefinitely)
                    .Subscribe(progress =>
                    {
                        Console.WriteLine($@"Current upload progress:
                            {progress.ProgressEstimate * 100}%");
                    });
            token.Dispose();
            // :snippet-end: upload-download-progress-notification
            var id = 2;
            var myObj = new ProgressObj
            {
                Id = id
            };
            realm.Write(() =>
            {
                realm.Add(myObj);
            });
            realm.Write(() =>
            {
                realm.RemoveAll<ProgressObj>();
            });
            
        }

        [Test]
        // :snippet-start: connection-state
        // :replace-start: {
        //  "terms": {
        //   "TestSessionConnnectionState": "SetupRealm"}
        // }
        public void TestSessionConnnectionState()
        {
            var appConfig = new AppConfiguration(myRealmAppId);
            app = App.Create(appConfig);
            user = app.LogInAsync(Credentials.Anonymous()).Result;
            config = new PartitionSyncConfiguration("myPartition", user);
            try
            {
                var realm = Realm.GetInstance(config);
                var session = realm.SyncSession;
                session.PropertyChanged += SyncSessionPropertyChanged!;
                realm.Dispose();
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
        }

        private void SyncSessionPropertyChanged(object sender, PropertyChangedEventArgs e)
        {
            if (e.PropertyName == nameof(Session.ConnectionState))
            {
                var session = (Session)sender;
                var currentState = session.ConnectionState;

                if (currentState == ConnectionState.Connecting)
                {
                    //session is connecting
                }

                if (currentState == ConnectionState.Connected)
                {
                    //session is connected
                }

                if (currentState == ConnectionState.Disconnected)
                {
                    //session has been disconnected
                }
            }
        }
        // :replace-end: 
        // :snippet-end:
        public void CollectionChanges()
        {
            using var realm = Realm.GetInstance();
            var container = realm.Write(() =>
            {
                return realm.Add(new Container());
            });

            // :snippet-start: notify-set-change
            var stringSet = container.StringSet.AsRealmCollection();

            stringSet.CollectionChanged += (sender, e) =>
            {
                Console.WriteLine($"Set {sender} changed: {e.Action}");
            };

            stringSet.PropertyChanged += (sender, e) =>
            {
                Console.WriteLine($"Property changed on {sender}: {e.PropertyName}");
            };
            // :snippet-end:
            // :snippet-start: notify-list-change
            var list = container.StringList.AsRealmCollection();

            list.CollectionChanged += (sender, e) =>
            {
                Console.WriteLine($"List {sender} changed: {e.Action}");
            };

            list.PropertyChanged += (sender, e) =>
            {
                Console.WriteLine($"Property changed on {sender}: {e.PropertyName}");
            };
            // :snippet-end:
            // :snippet-start: notify-dictionary-change
            var dictionary = container.IntDictionary.AsRealmCollection();

            dictionary.CollectionChanged += (sender, e) =>
            {
                Console.WriteLine($"Collection {sender} changed: {e.Action}");
            };

            dictionary.PropertyChanged += (sender, e) =>
            {
                Console.WriteLine($"Property changed on {sender}: {e.PropertyName}");
            };
            // :snippet-end:
        }
    }
    public partial class Container : IRealmObject
    {
        [PrimaryKey]
        public string _id { get; set; }
        public ISet<string> StringSet { get; } = null!;
        public IDictionary<string, int> IntDictionary { get; } = null!;
        public IList<string> StringList { get; } = null!;
    }
}