code: func (c *Client) TerminateStream(ctx context.Context, in *s.TerminateStreamRequest, opts ...grpc.CallOption) (
  	*empty.Empty, error) {
  
  	_, err := c.bundleRPC(ctx, opts, &s.BatchRequest_Entry{
  		Value: &s.BatchRequest_Entry_TerminateStream{TerminateStream: in},
  	})
  	if err != nil {
  		return nil, err
  	}
  
  	return &empty.Empty{}, nil
  }
docs: // TerminateStream implements ServicesClient.