Method next

packages/microservices/server/server-grpc.ts:412–421

(value)

      subscription.add(
        source.subscribe({
          next(value) {
            if (writing) {
              writing = call.write(value);
            } else {
              class="cm">// If we canclass="st">'t write, that's because we need to
              class="cm">// wait for the drain event before we can write again
              class="cm">// buffer the value and wait for the drain event
              valuesWaitingToBeDrained.push(value);
            }
          },
          error(err) {
            if (valuesWaitingToBeDrained.length === 0) {
              class="cm">// We're not waiting for a drain event, so we can just