diff --git a/src/query/streaming.ts b/src/query/streaming.ts
index 4035fd9..30fc837 100644
--- a/src/query/streaming.ts
+++ b/src/query/streaming.ts
@@ -62,6 +62,7 @@ export default class StreamingRpcQuery extends SimpleRpcQuery {
         }
 
         if (this._canceled) {
+          socket.write(pack({ cancel: true }));
           finish();
           return;
         }