0.2.6 #49
@@ -147,7 +147,7 @@ export class SynchronizedFormImpl<
|
|||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
get run(): Effect.Effect<void, TER> {
|
get run(): Effect.Effect<void, TER, never> {
|
||||||
return this.runSemaphore.withPermits(1)(Effect.provide(
|
return this.runSemaphore.withPermits(1)(Effect.provide(
|
||||||
Stream.runForEach(
|
Stream.runForEach(
|
||||||
Stream.drop(this.target.changes, 1),
|
Stream.drop(this.target.changes, 1),
|
||||||
|
|||||||
Reference in New Issue
Block a user