From 666271e96658dbc463c99f823ac0cd27c1ba9339 Mon Sep 17 00:00:00 2001
From: Tim <hello@timsmart.co>
Date: Tue, 19 Sep 2023 15:45:33 +1200
Subject: [PATCH] docs

---
 docs/rx/Registry.ts.md      |  2 --
 docs/rx/Rx.ts.md            |  8 --------
 packages/rx/test/Rx.test.ts | 19 -------------------
 3 files changed, 29 deletions(-)

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<A> {
       readonly immediate?: boolean
     }
   ) => void
-  readonly subscribeWithPrevious: <A>(
-    rx: Rx<A>,
-    f: (prev: Option.Option<A>, value: A) => void,
-    options?: {
-      readonly immediate?: boolean
-    }
-  ) => void
-  readonly queue: <A>(rx: Rx<A>) => Effect.Effect<never, never, Queue_.Dequeue<A>>
 }
 ```
 
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),