diff --git a/packages/effect-fc/src/Form.ts b/packages/effect-fc/src/Form.ts
index 16577e4..15ca682 100644
--- a/packages/effect-fc/src/Form.ts
+++ b/packages/effect-fc/src/Form.ts
@@ -63,16 +63,20 @@ export namespace make {
         readonly onSubmit: (
             this: Form<NoInfer<A>, NoInfer<I>, NoInfer<R>, unknown, unknown, unknown>,
             value: NoInfer<A>,
-        ) => Effect.Effect<SA, SE, SR>
+        ) => Effect.Effect<SA, SE, Result.forkEffectPubSub.InputContext<SR, NoInfer<SP>>>
         readonly initialSubmitProgress?: SP
         readonly autosubmit?: boolean
         readonly debounce?: Duration.DurationInput
     }
+
+    export type Success<A, I, R, SA = void, SE = A, SR = never, SP = never> = (
+        Form<A, I, R, SA, SE, Exclude<SR, Result.Progress<any> | Result.Progress<never>>, SP>
+    )
 }
 
 export const make = Effect.fnUntraced(function* <A, I = A, R = never, SA = void, SE = A, SR = never, SP = never>(
     options: make.Options<A, I, R, SA, SE, SR, SP>
-): Effect.fn.Return<Form<A, I, R, SA, SE, SR, SP>> {
+): Effect.fn.Return<make.Success<A, I, R, SA, SE, SR, SP>> {
     const valueRef = yield* SubscriptionRef.make(Option.none<A>())
     const errorRef = yield* SubscriptionRef.make(Option.none<ParseResult.ParseError>())
     const validationFiberRef = yield* SubscriptionRef.make(Option.none<Fiber.Fiber<A, ParseResult.ParseError>>())
@@ -80,7 +84,7 @@ export const make = Effect.fnUntraced(function* <A, I = A, R = never, SA = void,
 
     return new FormImpl(
         options.schema,
-        options.onSubmit,
+        options.onSubmit as any,
         options.initialSubmitProgress as SP,
         options.autosubmit ?? false,
         Option.fromNullable(options.debounce),
@@ -149,7 +153,7 @@ export const submit = <A, I, R, SA, SE, SR, SP>(
 ): Effect.Effect<
     Option.Option<Result.Result<SA, SE, SP>>,
     NoSuchElementException,
-    Scope.Scope | Result.forkEffectPubSub.OutputContext<SR>
+    Scope.Scope | SR
 > => Effect.whenEffect(
     self.valueRef.pipe(
         Effect.andThen(identity),
@@ -185,11 +189,17 @@ export const submit = <A, I, R, SA, SE, SR, SP>(
 export namespace service {
     export interface Options<in out A, in out I, in out R, in out SA = void, in out SE = A, out SR = never, in out SP = never>
     extends make.Options<A, I, R, SA, SE, SR, SP> {}
+
+    export type Return<A, I, R, SA = void, SE = A, SR = never, SP = never> = Effect.Effect<
+        Form<A, I, R, SA, SE, Exclude<SR, Result.Progress<any> | Result.Progress<never>>, SP>,
+        never,
+        Scope.Scope | R | Exclude<SR, Result.Progress<any> | Result.Progress<never>>
+    >
 }
 
 export const service = <A, I = A, R = never, SA = void, SE = A, SR = never, SP = never>(
     options: service.Options<A, I, R, SA, SE, SR, SP>
-): Effect.Effect<Form<A, I, R, SA, SE, SR, SP>, never, Scope.Scope | R | SR> => Effect.tap(
+): service.Return<A, I, R, SA, SE, SR, SP> => Effect.tap(
     make(options),
     form => Effect.forkScoped(run(form)),
 )
diff --git a/packages/effect-fc/src/Result.ts b/packages/effect-fc/src/Result.ts
index 07b9e32..23318f8 100644
--- a/packages/effect-fc/src/Result.ts
+++ b/packages/effect-fc/src/Result.ts
@@ -186,7 +186,7 @@ export const makeProgressLayer = <A, E, P = never>(): Layer.Layer<
 }))
 
 
-export namespace forkEffect {
+export namespace forkEffectSubscriptionRef {
     export type InputContext<R, P> = R extends Progress<infer X> ? [X] extends [P] ? R : never : R
     export type OutputContext<R> = Scope.Scope | Exclude<R, Progress<any> | Progress<never>>
 
@@ -195,13 +195,13 @@ export namespace forkEffect {
     }
 }
 
-export const forkEffect = <A, E, R, P = never>(
-    effect: Effect.Effect<A, E, forkEffect.InputContext<R, NoInfer<P>>>,
-    options?: forkEffect.Options<P>,
+export const forkEffectSubscriptionRef = <A, E, R, P = never>(
+    effect: Effect.Effect<A, E, forkEffectSubscriptionRef.InputContext<R, NoInfer<P>>>,
+    options?: forkEffectSubscriptionRef.Options<P>,
 ): Effect.Effect<
     Subscribable.Subscribable<Result<A, E, P>>,
     never,
-    forkEffect.OutputContext<R>
+    forkEffectSubscriptionRef.OutputContext<R>
 > => Effect.tap(
     SubscriptionRef.make<Result<A, E, P>>(initial()),
     ref => Effect.forkScoped(State<A, E, P>().pipe(
@@ -220,9 +220,12 @@ export const forkEffect = <A, E, R, P = never>(
 ) as Effect.Effect<Subscribable.Subscribable<Result<A, E, P>>, never, Scope.Scope>
 
 export namespace forkEffectPubSub {
-    export type InputContext<R, P> = forkEffect.InputContext<R, P>
-    export type OutputContext<R> = forkEffect.OutputContext<R>
-    export interface Options<P> extends forkEffect.Options<P> {}
+    export type InputContext<R, P> = R extends Progress<infer X> ? [X] extends [P] ? R : never : R
+    export type OutputContext<R> = Scope.Scope | Exclude<R, Progress<any> | Progress<never>>
+
+    export interface Options<P> {
+        readonly initialProgress?: P
+    }
 }
 
 export const forkEffectPubSub = <A, E, R, P = never>(