legacy-libs/grpc-cloned/node_modules/@grpc/grpc-js/build/src/filter-stack.js

   1 "use strict";
   2 Object.defineProperty(exports, "__esModule", { value: true });
   3 class FilterStack {
   4     constructor(filters) {
   5         this.filters = filters;
   6     }
   7     sendMetadata(metadata) {
   8         let result = metadata;
   9         for (let i = 0; i < this.filters.length; i++) {
  10             result = this.filters[i].sendMetadata(result);
  11         }
  12         return result;
  13     }
  14     receiveMetadata(metadata) {
  15         let result = metadata;
  16         for (let i = this.filters.length - 1; i >= 0; i--) {
  17             result = this.filters[i].receiveMetadata(result);
  18         }
  19         return result;
  20     }
  21     sendMessage(message) {
  22         let result = message;
  23         for (let i = 0; i < this.filters.length; i++) {
  24             result = this.filters[i].sendMessage(result);
  25         }
  26         return result;
  27     }
  28     receiveMessage(message) {
  29         let result = message;
  30         for (let i = this.filters.length - 1; i >= 0; i--) {
  31             result = this.filters[i].receiveMessage(result);
  32         }
  33         return result;
  34     }
  35     receiveTrailers(status) {
  36         let result = status;
  37         for (let i = this.filters.length - 1; i >= 0; i--) {
  38             result = this.filters[i].receiveTrailers(result);
  39         }
  40         return result;
  41     }
  42 }
  43 exports.FilterStack = FilterStack;
  44 class FilterStackFactory {
  45     constructor(factories) {
  46         this.factories = factories;
  47     }
  48     createFilter(callStream) {
  49         return new FilterStack(this.factories.map((factory) => factory.createFilter(callStream)));
  50     }
  51 }
  52 exports.FilterStackFactory = FilterStackFactory;
  53 //# sourceMappingURL=filter-stack.js.map