This is documentation for the next version of K6. For the latest stable release, go to the latest version.
Event Handler
The function to call for various events on the gRPC stream. It is set up using the stream.on()
method.
Example
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);
};