From a7c8719864d9b794e80f4762b15f408e7e5b1967 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Julien=20Valverd=C3=A9?= Date: Thu, 30 Apr 2026 02:14:28 +0200 Subject: [PATCH] Fix --- packages/effect-fc/src/SynchronizedForm.ts | 28 +++++++++++----------- 1 file changed, 14 insertions(+), 14 deletions(-) diff --git a/packages/effect-fc/src/SynchronizedForm.ts b/packages/effect-fc/src/SynchronizedForm.ts index 923296e..fb73bdd 100644 --- a/packages/effect-fc/src/SynchronizedForm.ts +++ b/packages/effect-fc/src/SynchronizedForm.ts @@ -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 Lens from "./Lens.js" import * as Subscribable from "./Subscribable.js" @@ -104,20 +104,20 @@ export class SynchronizedFormImpl< ), ), - Stream.runForEach( - Stream.drop(this.target.changes, 1), + // Stream.runForEach( + // Stream.drop(this.target.changes, 1), - targetValue => Schema.encode(this.schema, { errors: "all" })(targetValue).pipe( - Effect.flatMap(encodedValue => Effect.whenEffect( - Lens.set(this.encodedValue, encodedValue), - Effect.map( - Lens.get(this.encodedValue), - currentEncodedValue => !Equal.equals(encodedValue, currentEncodedValue), - ), - )), - Effect.ignore, - ), - ), + // targetValue => Schema.encode(this.schema, { errors: "all" })(targetValue).pipe( + // Effect.flatMap(encodedValue => Effect.whenEffect( + // Lens.set(this.encodedValue, encodedValue), + // Effect.map( + // Lens.get(this.encodedValue), + // currentEncodedValue => !Equal.equals(encodedValue, currentEncodedValue), + // ), + // )), + // Effect.ignore, + // ), + // ), ], { concurrency: "unbounded" }), this.context,