From cf8502eea5b3802a6b8ef095341f2aa8e97a057c Mon Sep 17 00:00:00 2001 From: bkim54 Date: Tue, 31 Jan 2017 10:42:50 -0800 Subject: [PATCH] updated return types to void of event listeners --- kafka-node/index.d.ts | 20 ++++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) diff --git a/kafka-node/index.d.ts b/kafka-node/index.d.ts index d77b180ef3..87a28f0ee7 100644 --- a/kafka-node/index.d.ts +++ b/kafka-node/index.d.ts @@ -13,24 +13,24 @@ export declare class Client { export declare class Producer { constructor(client: Client); - on(eventName: string, cb: () => any): Producer; - on(eventName: string, cb: (error: any) => any): Producer; + on(eventName: string, cb: () => any): void; + on(eventName: string, cb: (error: any) => any): void; send(payloads: Array, cb: (error: any, data: any) => any): void; createTopics(topics: Array, async: boolean, cb?: (error: any, data: any) => any): void; } export declare class HighLevelProducer { constructor(client: Client); - on(eventName: string, cb: () => any): HighLevelProducer; - on(eventName: string, cb: (error: any) => any): HighLevelProducer; + on(eventName: string, cb: () => any): void; + on(eventName: string, cb: (error: any) => any): void; send(payloads: Array, cb: (error: any, data: any) => any): void; createTopics(topics: Array, async: boolean, cb?: (error: any, data: any) => any): void; } export declare class Consumer { constructor(client: Client, fetchRequests: Array, options: ConsumerOptions); - on(eventName: string, cb: (message: string) => any): Consumer; - on(eventName: string, cb: (error: any) => any): Consumer; + on(eventName: string, cb: (message: string) => any): void; + on(eventName: string, cb: (error: any) => any): void; addTopics(topics: Array, cb: (error: any, added: boolean) => any): void; addTopics(topics: Array, cb: (error: any, added: boolean) => any, fromOffset: boolean): void; removeTopics(topics: Array, cb: (error: any, removed: boolean) => any): void; @@ -45,8 +45,8 @@ export declare class Consumer { export declare class HighLevelConsumer { constructor(client: Client, payloads: Array, options: ConsumerOptions); - on(eventName: string, cb: (message: string) => any): HighLevelConsumer; - on(eventName: string, cb: (error: any) => any): HighLevelConsumer; + on(eventName: string, cb: (message: string) => any): void; + on(eventName: string, cb: (error: any) => any): void; addTopics(topics: Array, cb: (error: any, added: boolean) => any): void; addTopics(topics: Array, cb: (error: any, added: boolean) => any, fromOffset: boolean): void; removeTopics(topics: Array, cb: (error: any, removed: boolean) => any): void; @@ -68,13 +68,13 @@ export declare class ConsumerGroup { export declare class Offset { constructor(client: Client); - on(eventName: string, cb: () => any): Offset; + on(eventName: string, cb: () => any): void; fetch(payloads: Array, cb: (error: any, data: any) => any): void; commit(groupId: string, payloads: Array, cb: (error: any, data: any) => any): void; fetchCommits(groupId: string, payloads: Array, cb: (error: any, data: any) => any): void; fetchLatestOffsets(topics: Array, cb: (error: any, data: any) => any): void; fetchEarliestOffsets(topics: Array, cb: (error: any, data: any) => any): void; - on(eventName: string, cb: (error: any) => any): Offset; + on(eventName: string, cb: (error: any) => any): void; } export declare class KeyedMessage {