diff --git a/src/index.ts b/src/index.ts index eb42e7e..247d5be 100644 --- a/src/index.ts +++ b/src/index.ts @@ -281,10 +281,8 @@ export class StreamingRpcQuery extends SimpleRpcQuery { get result(): Promise { return (this._promise as Promise) - .then( - (result): [sendUpdate: DataFn, response: Promise] => result[1] - ) - .then((response: any) => { + .then((result): Promise => result) + .then((response: ErrTuple) => { if (response[1]) { return { error: response[1] }; }