diff --git a/packages/transport/src/transports/abstractApi.ts b/packages/transport/src/transports/abstractApi.ts index cd6ab89600..6c2f4b85b8 100644 --- a/packages/transport/src/transports/abstractApi.ts +++ b/packages/transport/src/transports/abstractApi.ts @@ -370,7 +370,9 @@ export abstract class AbstractApiTransport extends AbstractTransport { signal, logger: this.logger, }); - thpState?.sync('send', name); + if (thpState && !thpState.isPiggybackAckEnabled) { + thpState.sync('send', name); + } } else { sendResult = await sendChunks(chunks, apiWrite); } diff --git a/packages/transport/src/transports/bridge.ts b/packages/transport/src/transports/bridge.ts index 0e3dbf7f49..5202488ea7 100644 --- a/packages/transport/src/transports/bridge.ts +++ b/packages/transport/src/transports/bridge.ts @@ -299,8 +299,8 @@ export class BridgeTransport extends AbstractTransport { if (!response.success) { return response; } - if (protocol.name === 'v2') { - thpState?.sync('send', name); + if (protocol.name === 'v2' && thpState && !thpState.isPiggybackAckEnabled) { + thpState.sync('send', name); } return this.success(undefined);