in out_writeapi.go [482:484]
func (r *realManagedWriterClient) BatchCommitWriteStreams(ctx context.Context, req *storagepb.BatchCommitWriteStreamsRequest, opts ...gax.CallOption) (*storagepb.BatchCommitWriteStreamsResponse, error) {
return r.currClient.BatchCommitWriteStreams(ctx, req, opts...)
}