- createQueueAtom<C, T>(context, consumer): player-types/packages/core/state/Types
-
Type Parameters
-
C extends ExecutionContext<{
state: {
UnsubscribedError: typeof UnsubscribedError;
create: (<Data, Modifiers>(initialValue, modifiers) => StateAtom<Data, Modifiers>);
dispatch: (<Modifier>(modifier, ...payload) => void);
subscribe: (<Ctx, Atom, A>(context, atom, task, errorCallback?) => Unsubscribe);
};
} & {
events: {
subscribe: (<Ctx, Element_1, EventKey>(context, element, event, subscriber) => Unsubscribe);
};
} & {
loop: ((signal) => Promise<void>);
} & {
timeout: ((signal, durationMs) => Abortable<void>);
} & {
abortable: (<T>(callback) => Abortable<T>);
}, EmptyObject, C>
-
T
Parameters
-
context: C
-
consumer: Task<C, T, void>