Skip to content

Commit

Permalink
fixed lint
Browse files Browse the repository at this point in the history
  • Loading branch information
jessekelly881 committed Apr 20, 2024
1 parent afa9b2b commit f950746
Showing 1 changed file with 4 additions and 6 deletions.
10 changes: 4 additions & 6 deletions packages/rx/src/Rx.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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"
Expand Down Expand Up @@ -299,7 +299,7 @@ const RxRuntimeProto = {
)
}))
},

sub(this: RxRuntime<any, any>, arg: any) {
return makeSub(readable((get) => {
const previous = get.self<Result.Result<any, any>>()
Expand All @@ -315,7 +315,6 @@ const RxRuntimeProto = {
)
}))
}

}

const WritableProto = {
Expand Down Expand Up @@ -560,7 +559,6 @@ export interface RxRuntime<R, ER> extends Rx<Result.Result<Runtime.Runtime<R>, E
| Effect.Effect<Subscribable.Subscribable<A, E, R>, E1, R>
| Rx.Read<Effect.Effect<Subscribable.Subscribable<A, E, R>, E1, R>>
) => Rx<Result.Result<A, E | E1>>

}

/**
Expand Down Expand Up @@ -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
Expand Down

0 comments on commit f950746

Please sign in to comment.