ProcessedValue.R3 1.1.0

ProcessedValue.R3

ProcessedValue.R3 is an extension of ProcessedValue for the R3 library. ProcessedValue.R3 allows using reactive variables from R3 in Commands for Processed. Commands now store subscriptions to reactive variables. When a reactive variable is updated, the command marks ProcessedValues as dirty.

The main methods of the classes remain the same as in ProcessedValue.
See also: https://github.com/GeroiGorodskoyZastroiki/ProcessedValue

Requirements

• ProcessedValue — required dependency (project reference to ProcessedValue project)
• R3 — reactive programming library (version 1.3.0 or later, via NuGet)

Main Components

• DisposableCommand<TSort, TValue> — command with R3 reactive subscriptions support
• DisposableProcessed<TSort, TValue> — container with commands and IDisposable support
• ReactiveProcessed<TSort, TValue> — reactive container with automatic value updates

Usage

Simple Command with Reactive Variable

// Create DisposableCommand and pass ReactiveProperty through constructor
ReactiveProperty<bool> reactiveProperty = new ReactiveProperty<bool>();
DisposableCommand<bool> disposableCommand = new DisposableCommand<bool>(
    (ref bool value) => value = reactiveProperty.Value, 
    new object[] { reactiveProperty }
);

// Add ReactiveProperty manually
disposableCommand.AddSubscriptionsToReactiveProperties(new object[] { reactiveProperty });

// Add single ReactiveProperty manually
disposableCommand.AddSubscriptionToReactiveProperty<bool>(ref reactiveProperty);

Command Management

// Create DisposableProcessed and add command
DisposableProcessed<bool> disposableProcessed = new DisposableProcessed<bool>();
disposableProcessed.AddCommand(disposableCommand, 0);

// Add regular commands alongside DisposableCommand
Command<bool> command = new Command<bool>((ref bool x) => x = false);
disposableProcessed.AddCommand(command, 0);

// Remove command by priority
disposableProcessed.RemoveCommand(command, 0);

// Remove command from all priorities
disposableProcessed.RemoveCommandAtAll(command);

// Check if command exists
bool exists = disposableProcessed.ContainsCommand(command);

Reactive Processed with Subscription

// Create ReactiveProcessed
ReactiveProcessed<bool> reactiveProcessed = new ReactiveProcessed<bool>();

// Subscribe to value changes - automatically recalculates when dirty
reactiveProcessed.Value.Subscribe(newValue => 
{
    Console.WriteLine($"Value updated: {newValue}");
    OnValueChanged(newValue);
});

// You can also get current value directly
bool currentValue = reactiveProcessed.Value.Value;

Lifecycle Management

// Dispose command subscriptions to ReactiveProperty
disposableCommand.Dispose();

// Dispose Processed - remove from list to set dirty on ReactiveProperty update for each command
disposableProcessed.Dispose();

Shortnames

Each class has a shortname: