Skip to content

Commit

Permalink
Clean trash
Browse files Browse the repository at this point in the history
  • Loading branch information
bigslycat committed Oct 19, 2018
1 parent b44cdc4 commit ecff155
Showing 1 changed file with 3 additions and 23 deletions.
26 changes: 3 additions & 23 deletions packages/honeycombs/src/Honeycomb.js
Original file line number Diff line number Diff line change
Expand Up @@ -61,29 +61,21 @@ class Honeycomb<S> extends StoreObservable<S>
}

apply<P>(handler: P => (S => S) | S): bee.Bee<S, P> {
return this.case(handler);
}

case<P>(handler: P => (S => S) | S): bee.Bee<S, P> {
const createCaseEmitters = this.#createCaseEmitters;
const { queue, store, caseSubject, next } = createCaseEmitters();
return bee.of(store, caseSubject, queue.case(handler, next));
}

transform(handler: S => S): bee.Bee<S, void> {
return this.case(() => handler);
return this.apply(() => handler);
}

always(payload: S): bee.Bee<S, void> {
return this.case(() => payload);
return this.apply(() => payload);
}

just(): bee.Bee<S, S> {
return this.case(payload => payload);
}

willBee<P>(handler: P => Promise<(S => S) | S>): Bee<S, P> {
return this.fromPromise(handler);
return this.apply(payload => payload);
}

fromPromise<P>(handler: P => Promise<(S => S) | S>): bee.Bee<S, P> {
Expand All @@ -92,10 +84,6 @@ class Honeycomb<S> extends StoreObservable<S>
return bee.of(store, caseSubject, queue.fromPromise(handler, next, error));
}

willBees<P>(handler: P => ObservableInterface<(S => S) | S>): Bee<S, P> {
return this.fromObservable(handler);
}

fromObservable<P>(handler: P => ObservableLike<(S => S) | S>): bee.Bee<S, P> {
const createCaseEmitters = this.#createCaseEmitters;
const { queue, store, caseSubject, next, error } = createCaseEmitters();
Expand All @@ -106,20 +94,12 @@ class Honeycomb<S> extends StoreObservable<S>
);
}

awaitBee<P>(handler: (S, P) => Promise<S>): Bee<S, P> {
return this.awaitPromise(handler);
}

awaitPromise<P>(handler: (S, P) => Promise<S>): bee.Bee<S, P> {
const createCaseEmitters = this.#createCaseEmitters;
const { queue, store, caseSubject, next, error } = createCaseEmitters();
return bee.of(store, caseSubject, queue.awaitPromise(handler, next, error));
}

awaitBees<P>(handler: (S, P) => ObservableInterface<S>): Bee<S, P> {
return this.awaitObservable(handler);
}

awaitObservable<P>(handler: (S, P) => ObservableLike<S>): bee.Bee<S, P> {
const createCaseEmitters = this.#createCaseEmitters;
const { queue, store, caseSubject, next, error } = createCaseEmitters();
Expand Down

0 comments on commit ecff155

Please sign in to comment.