flip/DefinitelyTyped
1
0
Fork 0
mirror of https://github.com/FlipsideCrypto/DefinitelyTyped.git synced 2026-02-06 10:56:53 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Add type parameters to channel definitions

Browse Source
This commit is contained in:
Paul Jolly 2015-08-20 10:17:13 +01:00
parent 38fb591c6e
commit 8a49a6fc14
1 changed files with 31 additions and 31 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

62
postal/postal.d.ts vendored
View File

@ -15,36 +15,36 @@ interface IResolver {
purge(options?: {topic?: string, binding?: string, compact?: boolean}): void;
}
interface ICallback {
(data: any, envelope: IEnvelope): void
interface ICallback<T> {
(data: T, envelope: IEnvelope<T>): void
}
interface ISubscriptionDefinition {
interface ISubscriptionDefinition<T> {
channel: string;
topic: string;
callback: ICallback;
callback: ICallback<T>;
// after and before lack documentation
constraint(predicateFn: (data: any, envelope: IEnvelope) => boolean): ISubscriptionDefinition;
constraints(predicateFns: ((data: any, envelope: IEnvelope) => boolean)[]): ISubscriptionDefinition;
context(theContext: any): ISubscriptionDefinition;
debounce(interval: number): ISubscriptionDefinition;
defer(): ISubscriptionDefinition;
delay(waitTime: number): ISubscriptionDefinition;
disposeAfter(maxCalls: number): ISubscriptionDefinition;
distinct(): ISubscriptionDefinition;
distinctUntilChanged(): ISubscriptionDefinition;
logError(): ISubscriptionDefinition;
once(): ISubscriptionDefinition;
throttle(interval: number): ISubscriptionDefinition;
subscribe(callback: ICallback): ISubscriptionDefinition;
constraint(predicateFn: (data: T, envelope: IEnvelope<T>) => boolean): ISubscriptionDefinition<T>;
constraints(predicateFns: ((data: T, envelope: IEnvelope<T>) => boolean)[]): ISubscriptionDefinition<T>;
context(theContext: any): ISubscriptionDefinition<T>;
debounce(interval: number): ISubscriptionDefinition<T>;
defer(): ISubscriptionDefinition<T>;
delay(waitTime: number): ISubscriptionDefinition<T>;
disposeAfter(maxCalls: number): ISubscriptionDefinition<T>;
distinct(): ISubscriptionDefinition<T>;
distinctUntilChanged(): ISubscriptionDefinition<T>;
logError(): ISubscriptionDefinition<T>;
once(): ISubscriptionDefinition<T>;
throttle(interval: number): ISubscriptionDefinition<T>;
subscribe(callback: ICallback<T>): ISubscriptionDefinition<T>;
unsubscribe(): void;
}
interface IEnvelope {
interface IEnvelope<T> {
topic: string;
data?: any;
data?: T;
/*Uses DEFAULT_CHANNEL if no channel is provided*/
channel?: string;
@ -53,10 +53,10 @@ interface IEnvelope {
}
interface IChannelDefinition {
subscribe(topic: string, callback: ICallback): ISubscriptionDefinition;
interface IChannelDefinition<T> {
subscribe(topic: string, callback: ICallback<T>): ISubscriptionDefinition<T>;
publish(topic: string, data?: any): void;
publish(topic: string, data?: T): void;
channel: string;
}
@ -73,24 +73,24 @@ interface IDestinationArg {
interface IPostal {
subscriptions: {};
wiretaps: ICallback[];
wiretaps: ICallback<any>[];
addWireTap(callback: ICallback): () => void;
addWireTap(callback: ICallback<any>): () => void;
channel(name?: string): IChannelDefinition;
channel<T>(name?: string): IChannelDefinition<T>;
getSubscribersFor(): ISubscriptionDefinition[];
getSubscribersFor(options: {channel?: string, topic?: string, context?: any}): ISubscriptionDefinition[];
getSubscribersFor(predicateFn: (sub: ISubscriptionDefinition) => boolean): ISubscriptionDefinition[];
getSubscribersFor(): ISubscriptionDefinition<any>[];
getSubscribersFor(options: {channel?: string, topic?: string, context?: any}): ISubscriptionDefinition<any>[];
getSubscribersFor(predicateFn: (sub: ISubscriptionDefinition<any>) => boolean): ISubscriptionDefinition<any>[];
linkChannels(source: ISourceArg | ISourceArg[], destination: IDestinationArg | IDestinationArg[]): void;
publish(envelope: IEnvelope): void;
publish(envelope: IEnvelope<any>): void;
reset(): void;
subscribe(options: {channel?: string, topic: string, callback: ICallback}): ISubscriptionDefinition;
unsubscribe(sub: ISubscriptionDefinition): void;
subscribe(options: {channel?: string, topic: string, callback: ICallback<any>}): ISubscriptionDefinition<any>;
unsubscribe(sub: ISubscriptionDefinition<any>): void;
unsubscribeFor(): void;
unsubscribeFor(options: {channel?: string, topic?: string, context?: any}): void;