@typed/fx/RefSubject

Stateful scan over a RefSubject / Computed, producing a Computed of the accumulated state.

Fx subscriptions follow Fx.scan semantics (emit initial, then fold each source value). Effect sampling accumulates across source versions via a private state ref (do not mix heavy subscribe + sample on the same scan if you need a single shared accumulator).

Effectful stateful scan over a RefSubject / Computed, producing a Computed of the accumulated state.

Defines the ref subject options state contract.

Creates a new RefSubject from a value, Effect, or Fx.

Builds a read-only Computed projection from a Versioned source.

Transforms a RefSubject, Computed, or Filtered using a pure function.

Transforms a RefSubject, Computed, or Filtered using an Effectful function.

Extract all values from an object using a Proxy. Allows accessing nested properties of a Computed or Filtered object/array as individual computed values.

Creates a named hydrated RefSubject using a string-encoded Schema codec.

Combines hydrated refs into one serialization and restoration boundary.

Canonical data attribute for the versioned envelope of unnamed hydrated refs.

Defines the hydrate options state contract.

Defines the hydrated ref subject state contract.

Defines the hydration attribute state contract.

Defines the hydration element state contract.

Defines the hydration ref state contract.

Runtime symbol exposing hydration metadata on a hydrated RefSubject.

Describes the any type.

Describes the hydration error type.

Describes the hydration services type.

Selects whether a computed Fx observes only its current value or also follows later pushes.

Limits which pushed versions a RefSubject view observes without changing its state.

Converts a Computed or Filtered of Option<A> into a Filtered<A>, filtering out None values.

Filters and transforms a RefSubject, Computed, or Filtered using a pure function that returns an Option.

Filters and transforms a RefSubject, Computed, or Filtered using an Effectful function that returns an Option.

Returns a Computed that yields the value inside the Option, or the fallback when None. Works with Computed<Option<A>> (e.g. from fromOption / fromNullable) and with Filtered<A>.

Builds a Filtered view from the three channels of a Versioned source.

A Computed is a read-only view of a value that can change over time. It is an Fx that emits the current value and subsequent updates. It is also an Effect that samples the current value.

A Filtered is a Computed that may not always have a value. It is essentially a Computed<Option<A>> with helper methods.

Defines the class state contract.

Defines the service state contract.

Creates a Context-backed RefSubject service facade and Layer constructors.

Lifts an Effect-provided Computed into a Computed facade.

Defers retrieval of a Filtered value from Effect Context while preserving Filtered behavior.

Creates a RefSubject from an Effect.

Creates a RefSubject from an Fx, tracking the latest emitted value.

Creates Option-valued RefSubject state from a nullable input.

Creates a RefSubject from an Option value.

Creates a RefSubject that tracks the latest value emitted by an Effect Stream.

Combines multiple RefSubject, Computed, or Filtered instances into a single struct.

Combines multiple RefSubject, Computed, or Filtered instances into a single tuple.

Decrements a numeric RefSubject by 1.

Resets a RefSubject to its initial value, returning the previous value if it existed.

Increments a numeric RefSubject by 1.

Resets a RefSubject to its initial value, returning the previous value if it existed.

Sets the value of a RefSubject.

Updates a RefSubject using a pure function.

Updates a RefSubject using an Effectful function.

Interface for basic RefSubject operations: get, set, delete.

Modifies a RefSubject using a pure function that returns both a result and a new value.

Modifies a RefSubject using an Effectful function that returns both a result and a new value.

Runs an effect that can modify a RefSubject transactionally, with optional interrupt handling.

Tests whether a value carries the public Computed TypeId.

Tests whether a value carries callable hydration metadata.

Checks if a value is a RefSubject.

Runtime symbol identifying read-only Computed values.

Runtime symbol identifying conditionally available Filtered values.

Runtime symbol identifying writable RefSubject values.

Describes the any type.

Describes the error type.

Describes the any type.

Describes the identifier type.

Describes the any type.

Describes the services type.

Describes the success type.

A RefSubject is a mutable reference that can be observed as an Fx. It combines the capabilities of a Ref (get/set/update) with a Subject (subscribe).

Transforms a RefSubject invariantly using bidirectional mapping functions.