Skip to content

Fix gRPC response stream [Replace AsyncPipe with BoundedPriorityQueue] #261

@prachi30

Description

@prachi30

Currently send method for gRPC response stream does not await while adding messages to async pipe and that is causing issues in case when a new message is added to response stream while the last one is still pending.

Here's the stack trace:
fields":{"stack":["Error: there is already a pending send call\n at /usr/src/node_modules/@walmartlabs/cookie-cutter-core/dist/utils/AsyncPipe.js:29:24\n at new Promise ()\n at AsyncPipe.send (/usr/src/node_modules/@walmartlabs/cookie-cutter-core/dist/utils/AsyncPipe.js:24:16)\n at GrpcResponseStream.send (/usr/src/node_modules/@walmartlabs/cookie-cutter-grpc/dist/internal/GrpcResponseStream.js:39:26)\n

Metadata

Metadata

Assignees

No one assigned

    Labels

    M-grpcThis issue is related to the gRPC moduleP1Priority 1bugSomething isn't working

    Type

    No type

    Projects

    No projects

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions