Thilawyn/effect-fc
1
0
Fork 0
Code Issues 1 Pull Requests 2 Actions Packages Projects Releases Wiki Activity

0.2.6 #49

Merged
Thilawyn merged 48 commits from next into master 2026-05-04 02:10:53 +02:00
Conversation 0 Commits 48 Files Changed 37 +14 -14
1 changed files with 14 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit a7c8719864 - Show all commits

28
packages/effect-fc/src/SynchronizedForm.ts
View File

@@ -1,4 +1,4 @@
import { Array, Cause, Chunk, type Context, Effect, Equal, Exit, Fiber, Option, ParseResult, Pipeable, Predicate, Schema, type Scope, Stream, SubscriptionRef } from "effect" import { Array, Cause, Chunk, type Context, Effect, Exit, Fiber, Option, ParseResult, Pipeable, Predicate, Schema, type Scope, Stream, SubscriptionRef } from "effect"
import * as Form from "./Form.js" import * as Form from "./Form.js"
import * as Lens from "./Lens.js" import * as Lens from "./Lens.js"
import * as Subscribable from "./Subscribable.js" import * as Subscribable from "./Subscribable.js"
@@ -104,20 +104,20 @@ export class SynchronizedFormImpl<
), ),
), ),
Stream.runForEach( // Stream.runForEach(
Stream.drop(this.target.changes, 1), // Stream.drop(this.target.changes, 1),
targetValue => Schema.encode(this.schema, { errors: "all" })(targetValue).pipe( // targetValue => Schema.encode(this.schema, { errors: "all" })(targetValue).pipe(
Effect.flatMap(encodedValue => Effect.whenEffect( // Effect.flatMap(encodedValue => Effect.whenEffect(
Lens.set(this.encodedValue, encodedValue), // Lens.set(this.encodedValue, encodedValue),
Effect.map( // Effect.map(
Lens.get(this.encodedValue), // Lens.get(this.encodedValue),
currentEncodedValue => !Equal.equals(encodedValue, currentEncodedValue), // currentEncodedValue => !Equal.equals(encodedValue, currentEncodedValue),
), // ),
)), // )),
Effect.ignore, // Effect.ignore,
), // ),
), // ),
], { concurrency: "unbounded" }), ], { concurrency: "unbounded" }),
this.context, this.context,