Back | Home
الـ Path الحالي: /home/picotech/domains/instantly.picotech.app/public_html/public/uploads/../uploads/../../../../instantly.picotech.app/homes/../../wa.picotech.app/public_html/node_modules/escape-html/../querystring/../@protobufjs/.././engine.io/../hasown/.././has-proto/../emoji-regex/../inherits/../real-require/.././punycode/../@eshaz/../hasown/../@hapi/../encodeurl/../protobufjs/src
الملفات الموجودة في هذا الـ Path:
.
..
common.js
converter.js
decoder.js
encoder.js
enum.js
field.js
index-light.js
index-minimal.js
index.js
mapfield.js
message.js
method.js
namespace.js
object.js
oneof.js
parse.js
reader.js
reader_buffer.js
root.js
roots.js
rpc
rpc.js
service.js
tokenize.js
type.js
types.js
typescript.jsdoc
util
util.js
verifier.js
wrappers.js
writer.js
writer_buffer.js
مشاهدة ملف: rpc.js
"use strict";
/**
* Streaming RPC helpers.
* @namespace
*/
var rpc = exports;
/**
* RPC implementation passed to {@link Service#create} performing a service request on network level, i.e. by utilizing http requests or websockets.
* @typedef RPCImpl
* @type {function}
* @param {Method|rpc.ServiceMethod<Message<{}>,Message<{}>>} method Reflected or static method being called
* @param {Uint8Array} requestData Request data
* @param {RPCImplCallback} callback Callback function
* @returns {undefined}
* @example
* function rpcImpl(method, requestData, callback) {
* if (protobuf.util.lcFirst(method.name) !== "myMethod") // compatible with static code
* throw Error("no such method");
* asynchronouslyObtainAResponse(requestData, function(err, responseData) {
* callback(err, responseData);
* });
* }
*/
/**
* Node-style callback as used by {@link RPCImpl}.
* @typedef RPCImplCallback
* @type {function}
* @param {Error|null} error Error, if any, otherwise `null`
* @param {Uint8Array|null} [response] Response data or `null` to signal end of stream, if there hasn't been an error
* @returns {undefined}
*/
rpc.Service = require("./rpc/service");