// 初始化
Akavache.Registrations.Start(applicationName: "AkavacheExperiment");
// 默认提供了四个常用持久化的方式：
// LocalMachine：默认持久化的文件保存在%LOCALAPPDATA%\ApplicationName\BlobCache文件夹下
// UserAccount：默认持久化的文件保存在%APPDATA%\ApplicationName\BlobCache文件夹下
// Secure：默认持久化的文件保存在%APPDATA%\ApplicationName\SecretCache文件夹下，数据加密
// InMemory：默认保存在内存中，数据加密
BlobCache.Secure
    .GetOrFetchObject("Key", () => GetTable())
    .Catch<DataTable, Exception>(ex =>
    {
        return Observable.Return(new DataTable());
    })
    .Subscribe(ar =>
    {
        dataReady = true;
    });

var jsonSerializerSettings = new JsonSerializerSettings
{
    Converters = new JsonConverter[] { new DataTableConverter() }
};
Splat.Locator.CurrentMutable.RegisterConstant(jsonSerializerSettings, typeof(JsonSerializerSettings));

var blobCache= new SQLitePersistentBlobCache(Path.Combine(Application.StartupPath, "LocalCache", "LocalCache.bin"));

[Fact]
public void KeyedOperationQueueCorrectlyShutsDown()
{
   var fixture = new KeyedOperationQueue();
   var op1 = new Subject<int>();
   var op2 = new Subject<int>();
   var op3 = new Subject<int>();
   bool isCompleted = false;

   int op1Result = 0, op2Result = 0, op3Result = 0;

   fixture.EnqueueObservableOperation("foo", () => op1).Subscribe(x => op1Result = x);
   fixture.EnqueueObservableOperation("bar", () => op2).Subscribe(x => op2Result = x);

   // Shut down the queue, shouldn't be completed until op1 and op2 complete
   fixture.ShutdownQueue().Subscribe(_ => isCompleted = true);
   Assert.False(isCompleted);

   op1.OnNext(1);
   op1.OnCompleted();
   Assert.False(isCompleted);
   Assert.Equal(1, op1Result);

   op2.OnNext(2);
   op2.OnCompleted();
   Assert.True(isCompleted);
   Assert.Equal(2, op2Result);

   // We've already shut down, new ops should be ignored
   fixture.EnqueueObservableOperation("foo", () => op3).Subscribe(x => op3Result = x);
   op3.OnNext(3);
   op3.OnCompleted();
   Assert.Equal(0, op3Result);
}