From f95074610a3854427240ead8af44b0b744f5ec3f Mon Sep 17 00:00:00 2001 From: Jesse Kelly Date: Sat, 20 Apr 2024 12:58:13 -0600 Subject: [PATCH] fixed lint --- packages/rx/src/Rx.ts | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/packages/rx/src/Rx.ts b/packages/rx/src/Rx.ts index 65b83cd..ce30004 100644 --- a/packages/rx/src/Rx.ts +++ b/packages/rx/src/Rx.ts @@ -18,8 +18,8 @@ import { type Pipeable, pipeArguments } from "effect/Pipeable" import * as Runtime from "effect/Runtime" import * as Scope from "effect/Scope" import * as Stream from "effect/Stream" -import * as SubscriptionRef from "effect/SubscriptionRef" import * as Subscribable from "effect/Subscribable" +import * as SubscriptionRef from "effect/SubscriptionRef" import * as internalRegistry from "./internal/registry.js" import { runCallbackSync } from "./internal/runtime.js" import * as Result from "./Result.js" @@ -299,7 +299,7 @@ const RxRuntimeProto = { ) })) }, - + sub(this: RxRuntime, arg: any) { return makeSub(readable((get) => { const previous = get.self>() @@ -315,7 +315,6 @@ const RxRuntimeProto = { ) })) } - } const WritableProto = { @@ -560,7 +559,6 @@ export interface RxRuntime extends Rx, E | Effect.Effect, E1, R> | Rx.Read, E1, R>> ) => Rx> - } /** @@ -723,11 +721,11 @@ export const subRef: { return Effect.isEffect(value) ? makeEffect(get, value, Result.initial(true)) : value })) - + // ----------------------------------------------------------------------------- // constructors - subscribable // ----------------------------------------------------------------------------- - + /** * @since 1.0.0 * @category constructors