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,