Skip to content

Commit 18e16f4

Browse files
committed
Add Observable.empty; bump to v0.1.2
1 parent 4e31f3a commit 18e16f4

File tree

3 files changed

+12
-1
lines changed

3 files changed

+12
-1
lines changed

package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "obgen",
3-
"version": "0.1.1",
3+
"version": "0.1.2",
44
"description": "Javascript Observables implemented with async generators",
55
"main": "dist/observable.js",
66
"types": "dist/observable.d.ts",

src/observable.ts

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -206,6 +206,11 @@ export default class Observable<T> {
206206
});
207207
}
208208

209+
/** Returns a new empty `Observable`, which emits no items and ends immediately. */
210+
static empty<T>(): Observable<T> {
211+
return Observable.create((stream) => stream.end());
212+
}
213+
209214
/**
210215
* Creates an `Observable` that, upon subscription, emits the provided value `val` and ends
211216
* immediately.

src/test/observable.test.ts

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -62,6 +62,12 @@ describe("Observable", () => {
6262
expect(await observable.toArray()).toEqual([[1]]);
6363
});
6464
});
65+
describe("#empyt", () => {
66+
it("should emit no items", async () => {
67+
const observable = Observable.empty();
68+
expect(await observable.toArray()).toEqual([]);
69+
});
70+
});
6571
describe("#defer", () => {
6672
it("should resolve promise upon subscription", async () => {
6773
const arr = [1];

0 commit comments

Comments
 (0)