mirror of
https://github.com/invoke-ai/InvokeAI.git
synced 2026-04-23 03:00:31 -04:00
tweak(ui): naming, code style
This commit is contained in:
@@ -24,7 +24,7 @@ type Deferred<T> = {
|
|||||||
/**
|
/**
|
||||||
* Create a promise and expose its resolve and reject callbacks.
|
* Create a promise and expose its resolve and reject callbacks.
|
||||||
*/
|
*/
|
||||||
const createDeferred = <T>(): Deferred<T> => {
|
const createDeferredPromise = <T>(): Deferred<T> => {
|
||||||
let resolve!: (value: T) => void;
|
let resolve!: (value: T) => void;
|
||||||
let reject!: (error: Error) => void;
|
let reject!: (error: Error) => void;
|
||||||
|
|
||||||
@@ -36,21 +36,21 @@ const createDeferred = <T>(): Deferred<T> => {
|
|||||||
return { promise, resolve, reject };
|
return { promise, resolve, reject };
|
||||||
};
|
};
|
||||||
|
|
||||||
interface QueueStatusEventHandler {
|
type QueueStatusEventHandler = {
|
||||||
subscribe: (handler: (event: S['QueueItemStatusChangedEvent']) => void) => void;
|
subscribe: (handler: (event: S['QueueItemStatusChangedEvent']) => void) => void;
|
||||||
unsubscribe: (handler: (event: S['QueueItemStatusChangedEvent']) => void) => void;
|
unsubscribe: (handler: (event: S['QueueItemStatusChangedEvent']) => void) => void;
|
||||||
}
|
};
|
||||||
|
|
||||||
interface GraphExecutor {
|
type GraphExecutor = {
|
||||||
enqueueBatch: (batch: EnqueueBatchArg) => Promise<{ item_ids: number[] }>;
|
enqueueBatch: (batch: EnqueueBatchArg) => Promise<{ item_ids: number[] }>;
|
||||||
getQueueItem: (id: number) => Promise<S['SessionQueueItem']>;
|
getQueueItem: (id: number) => Promise<S['SessionQueueItem']>;
|
||||||
cancelQueueItem: (id: number) => Promise<S['SessionQueueItem']>;
|
cancelQueueItem: (id: number) => Promise<S['SessionQueueItem']>;
|
||||||
}
|
};
|
||||||
|
|
||||||
interface GraphRunnerDependencies {
|
type GraphRunnerDependencies = {
|
||||||
executor: GraphExecutor;
|
executor: GraphExecutor;
|
||||||
eventHandler: QueueStatusEventHandler;
|
eventHandler: QueueStatusEventHandler;
|
||||||
}
|
};
|
||||||
|
|
||||||
type RunGraphArg = {
|
type RunGraphArg = {
|
||||||
graph: Graph;
|
graph: Graph;
|
||||||
@@ -105,7 +105,7 @@ type RunGraphReturn = {
|
|||||||
*/
|
*/
|
||||||
export const runGraph = (arg: RunGraphArg): Promise<RunGraphReturn> => {
|
export const runGraph = (arg: RunGraphArg): Promise<RunGraphReturn> => {
|
||||||
// A deferred promise works around the antipattern of async promise executors.
|
// A deferred promise works around the antipattern of async promise executors.
|
||||||
const { promise, resolve, reject } = createDeferred<RunGraphReturn>();
|
const { promise, resolve, reject } = createDeferredPromise<RunGraphReturn>();
|
||||||
_runGraph(arg, resolve, reject);
|
_runGraph(arg, resolve, reject);
|
||||||
return promise;
|
return promise;
|
||||||
};
|
};
|
||||||
|
|||||||
Reference in New Issue
Block a user