docs

tim-smart · Sep 19, 2023 · 666271e · 666271e
1 parent 878bfba
commit 666271e
Show file tree

Hide file tree

Showing 3 changed files with 0 additions and 29 deletions.
diff --git 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
@@ -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
@@ -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),