diff --git a/docs/rx/Registry.ts.md b/docs/rx/Registry.ts.md
index 3b93af4..2a739f8 100644
--- a/docs/rx/Registry.ts.md
+++ b/docs/rx/Registry.ts.md
@@ -48,8 +48,6 @@ export interface Registry {
readonly refresh: Rx.Rx.Refresh
readonly set: Rx.Rx.Set
readonly subscribe: Rx.Rx.Subscribe
- readonly subscribeWithPrevious: Rx.Rx.SubscribeWithPrevious
- readonly queue: Rx.Rx.Queue
}
```
diff --git a/docs/rx/Rx.ts.md b/docs/rx/Rx.ts.md
index bc49747..6156016 100644
--- a/docs/rx/Rx.ts.md
+++ b/docs/rx/Rx.ts.md
@@ -213,14 +213,6 @@ export interface Context {
readonly immediate?: boolean
}
) => void
- readonly subscribeWithPrevious: (
- rx: Rx,
- f: (prev: Option.Option, value: A) => void,
- options?: {
- readonly immediate?: boolean
- }
- ) => void
- readonly queue: (rx: Rx) => Effect.Effect>
}
```
diff --git a/packages/rx/test/Rx.test.ts b/packages/rx/test/Rx.test.ts
index e73d863..cc1b125 100644
--- a/packages/rx/test/Rx.test.ts
+++ b/packages/rx/test/Rx.test.ts
@@ -4,7 +4,6 @@ import * as Rx from "@effect-rx/rx/Rx"
import * as Context from "@effect/data/Context"
import * as Effect from "@effect/io/Effect"
import * as Layer from "@effect/io/Layer"
-import * as Queue from "@effect/io/Queue"
describe("Rx", () => {
it("get/set", () => {
@@ -51,24 +50,6 @@ describe("Rx", () => {
expect(r.get(counter)).toEqual(0)
})
- it("queue", async () => {
- const counter = Rx.state(0)
- const r = Registry.make()
-
- await Effect.gen(function*(_) {
- const q = yield* _(r.queue(counter))
- expect(yield* _(Queue.take(q))).toEqual(0)
- r.set(counter, 1)
- expect(yield* _(Queue.take(q))).toEqual(1)
- yield* _(Effect.yieldNow())
- expect(r.get(counter)).toEqual(1)
- }).pipe(
- Effect.scoped,
- Effect.runPromise
- )
- expect(r.get(counter)).toEqual(0)
- })
-
it("runtime", async () => {
const count = Rx.effect(
Effect.flatMap(Counter, (_) => _.get),