export function CreateGrpcEventStream()

in src/GrpcClient.ts [30:48]

• 17 lines of code
• 1 McCabe index (conditional complexity)

export function CreateGrpcEventStream(connection: string, grpcMaxMessageLength: number): IEventStream {
    const constructor: ServiceClientConstructor = GetGrpcClientConstructor();
    const clientOptions = {
        'grpc.max_send_message_length': grpcMaxMessageLength,
        'grpc.max_receive_message_length': grpcMaxMessageLength,
    };
    const client = new constructor(connection, grpc.credentials.createInsecure(), clientOptions);
    process.on('exit', () => {
        grpc.closeClient(client);
    });

    const eventStream = client.eventStream();

    eventStream.on('end', function () {
        eventStream.end();
        process.exit();
    });
    return eventStream;
}