PowRxVar 0.0.47

dotnet add package PowRxVar --version 0.0.47
NuGet\Install-Package PowRxVar -Version 0.0.47
This command is intended to be used within the Package Manager Console in Visual Studio, as it uses the NuGet module's version of Install-Package.
<PackageReference Include="PowRxVar" Version="0.0.47" />
For projects that support PackageReference, copy this XML node into the project file to reference the package.
paket add PowRxVar --version 0.0.47
#r "nuget: PowRxVar, 0.0.47"
#r directive can be used in F# Interactive and Polyglot Notebooks. Copy this into the interactive tool or source code of the script to reference the package.
// Install PowRxVar as a Cake Addin
#addin nuget:?package=PowRxVar&version=0.0.47

// Install PowRxVar as a Cake Tool
#tool nuget:?package=PowRxVar&version=0.0.47

PowRxVar

Table of content

Introduction

Provides reactive variables integrated with Rx.Net:

  • implement IObservable<T> so can be queried using reactive extensions
  • can access and set the current value
  • can be combined into other variables (Combine, Switch)

Basics

// Create variables
var a = Var.Make(3);
var b = Var.Make(7);

// Get and set the value
Console.WriteLine($"{a.V}"); // 3
a.V = 4;

// Combine variables
var c = Var.Combine(a, b, (va, vb) => va * 100 + vb);
Console.WriteLine($"{c.V}"); // 407
b.V = 8;
Console.WriteLine($"{c.V}"); // 408

// Dispose a variable
a.Dispose();
var valA = a.V; // Exception
var valB = b.V; // 8
var valC = c.V; // Exception

Combining with Expression Trees

There is a more general mechanism to combine any number of variables of any type:

var a = Var.Make(3);
var b = Var.Make(5);
var c = Var.Make(7);
var r = Var.Expr(() => a.V * 3 + b.V * 2 + c.V);

// r.V == 26

Similarly to Combine(), r will be disposed as soon as either a or b or c is disposed.

Note: this technique is slower to setup at runtime than using Combine() because of the need to compile expression trees.

Basic interfaces

Read only variable IRoVar<T>

interface IRoVar<out T> : IObservable<T>, IRoDispBase
{
  // IRoDispBase
  // -> can register a callback on disposal & tell if disposed
  IObservable<Unit> WhenDisposed { get; }
  bool IsDisposed { get; }

  // IObservable<T>
  // -> can use it as a normal observable
  IDisposable Subscribe(IObserver<T> observer);

  // -> can read its value
  T V { get; }
}

Read write variable IRwVar<T>

interface IRwVar<T> : IRoVar<T>, IObserver<T>, IRwDispBase
{
  // IRwDispBase
  // -> inherits from IRoDispBase but can also dispose it
  void Dispose();

  // IObserver<T>
  // -> can be updated by subscribing an observable to it
  void OnNext(T value);
  void OnCompleted();
  void OnError(Exception error);

  // -> can read and write its value
  T V { get; set; }
}

Note

As IRwVar<T> inherits from IRoVar<T> you can naturally use a read write variable in place where a read only one is required.

However, if you want to prevent the calling code from casting it back to an IRwVar<T>, you can use this extension method:

static IRoVar<T> ToReadOnly<T>(this IRwVar<T> v);

This is similar to Observable.AsObservable

Bound variables

When binding variables to a UI control, it's sometimes useful to differentiate between updates done by the user through the control (inner) and updates done by the code (outer).

Usage

// Create
var v = Var.MakeBnd(7);

// Set
v.SetInner(3);
v.SetOuter(5);

// Listen to updates
v.WhenInner.Subscribe(...);
v.WhenOuter.Subscribe(...);

// Get the latest value
Console.WriteLine($"{v.V}"); // 5

Similarly to IRoVar<T> & IRwVar<T>, bound variables use IRoBndVar<T> & IRwBndVar<T>

Bound variable interfaces

The interfaces here are more complex, but I believe they make sense.

  • IRoBndVar<T> : IRoVar<T> So a read only bound variable can listen to either:

    • the outer stream WhenOuter
    • the inner stream WhenInner
    • the merged stream through itself as it implements IObservable<T> through IRoVar<T>

    So IRoBndVar< T > is an IRoVar< T > in its merged variable

  • IFullRwBndVar<T> : IRwBndVar<T> additionally allows to:

    • set the inner value
    • set the outer value Functions that hook variables to the UI (both ways) will use this interface internally

    Setting var.V = xxx will set its outer value. So IFullRwBndVar< T > is an IRwVar< T > in its outer variable

  • IRwBndVar<T> this is the same as IFullRwBndVar<T> with the exception that it cannot set inner values Functions that hook variables to the UI (both ways) will return this interface to user code (as the user doesn't need to set the inner value - that's the role of the hook)

    Again, setting var.V = xxx will set its outer value. So IRwBndVar< T > is an IRwVar< T > in its outer variable

Ownership and disposable interfaces

Read only variables implement IRoDispBase

  • Can tell if it's disposed (bool IsDisposed)
  • Can React to a disposable (IObservable<Unit> WhenDisposed)
  • Cannot call Dispose()

Read write variables implement IRwDispBase

  • Inherits IRoDispBase
  • Additionally, Can call Dispose() (IDisposable)

License

MIT

Product Compatible and additional computed target framework versions.
.NET net7.0 is compatible.  net7.0-android was computed.  net7.0-ios was computed.  net7.0-maccatalyst was computed.  net7.0-macos was computed.  net7.0-tvos was computed.  net7.0-windows was computed.  net8.0 was computed.  net8.0-android was computed.  net8.0-browser was computed.  net8.0-ios was computed.  net8.0-maccatalyst was computed.  net8.0-macos was computed.  net8.0-tvos was computed.  net8.0-windows was computed. 
Compatible target framework(s)
Included target framework(s) (in package)
Learn more about Target Frameworks and .NET Standard.

NuGet packages (5)

Showing the top 5 NuGet packages that depend on PowRxVar:

Package Downloads
LINQPadExtras

LINQPad utility functions

PowRxVar.Maybe

Composable reactive variables

PowRxVar.WinForms

Composable reactive variables

PowLINQPad

Reactive control and utilities for LINQPad

ImdbLib

IMDB scraping

GitHub repositories

This package is not used by any popular GitHub repositories.

Version Downloads Last updated
0.0.47 267 8/19/2023
0.0.46 184 8/9/2023
0.0.45 164 7/9/2023
0.0.44 195 7/2/2023
0.0.43 178 6/23/2023
0.0.42 174 6/23/2023
0.0.41 175 6/23/2023
0.0.40 178 6/20/2023
0.0.38 179 6/19/2023
0.0.37 185 6/17/2023
0.0.36 176 6/17/2023
0.0.35 184 6/17/2023
0.0.34 186 6/16/2023
0.0.33 173 6/13/2023
0.0.32 173 6/13/2023
0.0.31 177 6/13/2023
0.0.30 180 6/13/2023
0.0.29 185 6/13/2023
0.0.28 168 6/13/2023
0.0.27 180 6/12/2023
0.0.25 226 6/5/2023
0.0.24 187 6/5/2023
0.0.23 177 6/3/2023
0.0.22 179 6/3/2023
0.0.21 188 6/2/2023
0.0.20 189 6/2/2023
0.0.19 186 6/2/2023
0.0.18 190 6/1/2023
0.0.17 234 5/28/2023
0.0.16 233 5/28/2023
0.0.15 236 4/24/2023
0.0.14 331 1/3/2023
0.0.11 369 11/26/2022
0.0.10 343 11/24/2022
0.0.9 348 11/18/2022
0.0.8 345 11/18/2022
0.0.7 374 11/15/2022
0.0.6 394 11/15/2022
0.0.4 539 11/13/2022
0.0.1 390 8/13/2022