Reactive Programming

Dataflow programming, the monadic way

Calulations over INotifyPropertyChanged and INotifyColectionChanged (ObservableCollection) objects. Results of the calculations are INotifyPropertyChanged and INotifyColectionChanged (ObservableCollection) objects. The calculations includes ones similar to LINQ and the calculation of arbitrary expression. Observable Calculations are implemented as extension methods, like LINQ ones. ObservableCalculations is implementation of reactive programming paradigm.

Introducing Reactive Programming, Flux Architecture, and standardized network requests to Blazor Components

A library with types enabling additional secnarios with reactive programming model.

The reactive, scalable, and resilient Object, CQRS, and Event Sourcing storage and projection tool for services and applications built on the vlingo/platform.

Fluor is a library that contains construction blocks for implicit reactive programming. Please visit https://github.com/Eric-W0/Fluor for documentation and sources.

Functional reactive programming with monads.

Cluster management for reactive, scalable resiliency of C# .NET tools and applications running on vlingo/actors.

[.NET 4.6.1+] - DisposableObservable: a class for creating Observable sequences with TPL easily as Observable.Create - [IObservable].Serialize: wrap all subscriptions into a single ISubject against the sourcing observable - [IObservable].AsAsync: execute all functions on TPL - [IObservable].Fork: add another subscription to the observable creating a new child observable stream - [IObservable].Where(filter, elseObservable): apply the where in the usual way, and generate an Else observable to continue work in the other case - [IObservable].ToJson: serialize in Json all values - [IObservable].ToCSV: serialize in CSV columns all values (configurable delimiter) - [IObservable].OnLastOrDefault: do something when observable completes - ObservableStreamReader: route binary data from a Stream to subscribers

Functional Reactive Programming Library for .NET. https://github.com/jerometerry/potassium http://www.jerometerry.com/potassium/

Example of SignalR with F-Sharp (and Silverlight 5 or Javascript): - SignalR is a library (for web-based Publish/Subscribe -pattern) on top of WebSockets, which is HTML5 API that enables bi-directional communication between the browser and server. SignalR will fallback to other techniques and technologies when WebSockets are not available. http://signalr.net/ - F-Sharp (F#) is multiparadigm (functional-first) programming language mainly for .NET environment. http://fsharp.org/ - This sample uses Reactive Extensions 2.1 to communicate with SignalR, on both client and server side. Reactive Extensions is a library to compose asynchronous and event-based programs using observable collections and LINQ-style query operators. http://msdn.microsoft.com/en-us/data/gg577609.aspx - For server side: This could work purely from F# as Owin (http://owin.org/) console application but now F#-server-side is called from an empty ASP.NET C# Web Application. (Still you can start OWin from F# Interactive...) - For client side: Silverlight 5.0 application using F#-library and Silverlight 5.0 XAML/C# application to show the user interface. http://www.silverlight.net There is also jQuery/JavaScript test page, if you don't want to use Silverlight. - This proof of concept/sample/tutorial/demo is developed with Visual Studio 2012. References are resolved via NuGet. F# compiler won't auto-restore packages on compile. So go first to Tools -> Library Package Manager -> NuGet and press "Restore" to restore all the references, and then rebuild. - SignalR supports two kinds of connections: Hub and PersistentConnection Both are working with Silverlight and JavaScript.

Provides reactive programming for ASP.NET Core SignalR client application.

RxState is a C# library that implements the Flux pattern, providing a streamlined way to manage state in .NET applications. It leverages reactive programming principles to create a predictable state container for applications.

Ultra light reactive library for XAML-binding applications

The vlingo/PLATFORM tooling for reactive Domain-Driven Design models that are highly concurrent. Includes Compute Grid, Actor Caching, Object Spaces, Cluster Cross-Node Messaging, CQRS, and Event Sourcing support.

The reactive, scalable, and resilient Object, CQRS, and Event Sourcing storage and projection tool built on top of ADO.NET for services and applications built on the vlingo/platform.

Vlingo Xoom

Provides ReactiveUI.Validation extensions for the AndroidX Library

Provides ReactiveUI.Validation extensions for the Android Support Library

Vlingo Xoom Turbo

a library for composing asynchronous and event-based programs using observable sequences and LINQ-style query operators. (iOS)

A Library for reactive programming

Net.Mqtt.ReactiveOrm is a lightweight Reactive Object Mapper (ROM) for MQTT-based applications in .NET. It abstracts MQTT topics as strongly typed, observable entities, enabling developers to handle real-time data streams using LINQ-style syntax and reactive programming patterns.

"CodeJunkie.Observables is a library for creating and managing observable collections and properties, enabling reactive programming patterns in .NET applications."

Advanced Dependency Injection (DI) integration tailored for Windows Forms applications. Built on top of `Microsoft.Extensions.DependencyInjection`, but adapted and extended to address WinForms-specific development needs.

JoeDevSharp.MqttNet.ReactiveBinding is a lightweight Reactive Object Mapper (ROM) for MQTT-based applications in .NET. It abstracts MQTT topics as strongly typed, observable entities, enabling developers to handle real-time data streams using LINQ-style syntax and reactive programming patterns.

This library provides the `NetDaemonRuntimeStateService`, which allows you to check and subscribe to the runtime state of `NetDaemon`.

Mqtt.Net.Orm is a lightweight Reactive Object Mapper (ROM) for MQTT-based applications in .NET. It abstracts MQTT topics as strongly typed, observable entities, enabling developers to handle real-time data streams using LINQ-style syntax and reactive programming patterns. Inspired by Entity Framework’s DbContext and DbSet<T> model, Mqtt.Net.Orm brings structure and clarity to messaging-driven systems by treating MQTT topics as first-class, observable data sources. This makes it easier to reason about, subscribe to, filter, and publish MQTT messages without dealing directly with low-level client code.

Collection of extension methods meant to enhance NetDaemon entities with stateful and boolean observables allowing for more robust implementations and a more intuitive coding experience.

The "Upnp" project provides a comprehensive library for discovering and interacting with Universal Plug and Play (UPnP) devices. It supports real-time device discovery, service description parsing, and reactive programming.

The "IpScanner" project provides a robust library for scanning IP address ranges to discover active network devices. It features reactive programming for real-time updates, asynchronous operations for efficient scanning, and integration with network abstractions and tools.

The "Tools" project provides a comprehensive set of utilities for network operations, including ARP table management, IP validation, network interface information, and real-time traffic monitoring. It simplifies network-related tasks with reusable components and reactive programming support.

Composable, reactive, and layered logic pipelines for automation.

A .NET library for monitoring USB device events, providing real-time notifications for device connections and disconnections with detailed logging and reactive programming support.

Reactive Extensions meant for stateful binary observables.

Collection of extension methods meant to enhance NetDaemon entities with stateful and boolean observables allowing for more robust implementations and a more intuitive coding experience.

Reactive Extensions meant specifically for implementations of IObservable<bool>.

This project contains a few reactive programming functionalities.

A reactive programming framework.

A reactive programming framework.