菜单
文档breadcrumb arrow Grafana k6breadcrumb arrow JavaScript APIbreadcrumb arrow k6/net/grpcbreadcrumb arrow Streambreadcrumb arrow 事件处理程序
开源

事件处理程序

用于处理 gRPC 流上各种事件的回调函数。使用 stream.on() 方法进行设置。

名称类型描述
dataobject 或 Error它是一个包含服务器数据的对象（消息），或者在发生 error 事件时是一个错误对象
metadata元数据表示 gRPC 流消息元数据的对象。

示例

JavaScript 
import { Client, Stream } from 'k6/net/grpc';
import { sleep } from 'k6';

const client = new Client();
client.load([], '../../grpc_server/route_guide.proto');

export default () => {
  if (__ITER == 0) {
    client.connect('127.0.0.1:10000', { plaintext: true });
  }

  const stream = new Stream(client, 'main.RouteGuide/RecordRoute');

  // sets up a handler for the data (server sends data) event
  stream.on('data', (stats, metadata) => {
    console.log('It took', stats.elapsedTime, 'seconds');
    console.log('This message has been received:', metadata.ts);
  });

  stream.on('end', function () {
    // The server has finished sending
    client.close();
  });

  sleep(1);
};