diff --git a/src/message-stream.ts b/src/message-stream.ts
index 073658382..2b21e13dd 100644
--- a/src/message-stream.ts
+++ b/src/message-stream.ts
@@ -318,17 +318,16 @@ export class MessageStream extends PassThrough {
       streamAckDeadlineSeconds: this._subscriber.ackDeadline,
       maxOutstandingMessages: this._subscriber.useLegacyFlowControl
         ? 0
-        : this._subscriber.maxMessages,
+        : this._subscriber.maxMessages / this._streams.length,
       maxOutstandingBytes: this._subscriber.useLegacyFlowControl
         ? 0
-        : this._subscriber.maxBytes,
+        : this._subscriber.maxBytes / this._streams.length,
     };
     const otherArgs = {
       headers: {
         'x-goog-request-params': 'subscription=' + this._subscriber.name,
       },
     };
-
     const stream: PullStream = client.streamingPull({deadline, otherArgs});
     this._replaceStream(index, stream);
     stream.write(request);