text:
package org.esupportail.publisher.web;

import java.io.IOException;

import javax.servlet.http.HttpServletRequest;

import com.fasterxml.jackson.databind.ObjectMapper;
import lombok.extern.slf4j.Slf4j;
import org.esupportail.publisher.security.CustomUserDetails;
import org.esupportail.publisher.security.SecurityUtils;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/app")
@Slf4j
public class LoginController {

    @RequestMapping("/login")
    public Object login(Model model, HttpServletRequest request) throws IOException {

        log.debug("=========> Login Call ");

        /*String then = request.getParameter("then");
        if (then != null) {
            log.debug("Going on redirect");
            // then = URLDecoder.decode(then, "UTF-8");
            String url = then;
            log.debug("url : {}", url);
            return "redirect:" + URI.create(url);
        }*/
        // retrieve the user
        CustomUserDetails user = SecurityUtils.getCurrentUserDetails();
        if (user == null) {
            return new ResponseEntity<>(HttpStatus.UNAUTHORIZED);
        }

        log.debug("UserDetails {}", user);
        //log.debug("#########   RedirectURL is present ? {}", getRedirectUrl(request));
        String uri = request.getRequestURI() + (request.getQueryString() != null ? "?" + request.getQueryString() : "");
        log.debug("#########   Requested url {}", uri);

        String jsUser = new ObjectMapper().writeValueAsString(user);
        String content, type;
        if (request.getParameter("postMessage") != null) {
            log.debug("Going on postMessage");
            type = "text/html";
            content = "Login success, please wait...\n<script>\n (window.opener ? (window.opener.postMessage ? window.opener : window.opener.document) : window.parent).postMessage('loggedUser=' + JSON.stringify("
                + jsUser + "), '*');\n</script>";
        } else if (request.getParameter("callback") != null) {
            log.debug("Going on callback");
            type = "application/x-javascript";
            content = request.getParameter("callback") + "(" + jsUser + ")";
        } else {
            log.debug("Going on else");
            type = "application/json";
            content = jsUser;
        }
        log.debug("content : {}", content);
        HttpHeaders responseHeaders = new HttpHeaders();
        responseHeaders.setContentType(MediaType.valueOf(type));
        return new ResponseEntity<String>(content, responseHeaders, HttpStatus.OK);
    }

    // @RequestMapping("/j_spring_cas_security_logout")
    // public String spring_logout() {
    // return "redirect:/logout";
    // }

    // @RequestMapping("/logout")
    // public String logout() {
    // return "redirect:/";
    // }

//    @RequestMapping(value = { "/", "" }, method = RequestMethod.GET)
//    public String index(Model model) {
//        Authentication auth = SecurityContextHolder.getContext().getAuthentication();
//        String user = auth.getName();
//        log.info("passing in /");
//        model.addAttribute("user", user);
//
//        // renders /WEB-INF/jsp/index.jsp
//        return "index";
//        // return "Hello World! (user: " + user + ")";
//    }
//
//    @RequestMapping(value = "/secure", method = RequestMethod.GET)
//    public String secure(Model model) {
//        Authentication auth = SecurityContextHolder.getContext().getAuthentication();
//        String user = auth.getName();
//        log.info("passing in /");
//        model.addAttribute("user", user);
//
//        // renders /WEB-INF/jsp/index.jsp
//        return "secure/index";
//        // return "Hello World! (user: " + user + ")";
//    }
//
//    @RequestMapping(value = "/filtered", method = RequestMethod.GET)
//    public String filtered(Model model) {
//        Authentication auth = SecurityContextHolder.getContext().getAuthentication();
//        String user = auth.getName();
//        log.info("passing in /");
//        model.addAttribute("user", user);
//
//        // renders /WEB-INF/jsp/index.jsp
//        return "secure/admin/index";
//        // return "Hello World! (user: " + user + ")";
//    }

//    protected String getRedirectUrl(HttpServletRequest request) {
//        HttpSession session = request.getSession(false);
//        if (session != null) {
//            SavedRequest savedRequest = new HttpSessionRequestCache().getRequest(request, null);
//            if (savedRequest != null) {
//                return savedRequest.getRedirectUrl();
//            }
//        }
//
//		/* return a sane default in case data isn't there */
//        return request.getContextPath() + "/";
//    }
}


text:
package com.intel.analytics.zoo.serving.http

import com.fasterxml.jackson.databind.ObjectMapper
import com.fasterxml.jackson.databind.module.SimpleModule
import com.intel.analytics.bigdl.nn.abstractnn.Activity
import com.intel.analytics.zoo.serving.TestUtils
import com.intel.analytics.zoo.serving.serialization
import com.intel.analytics.zoo.serving.utils.ConfigParser
import org.scalatest.{FlatSpec, Matchers}

class JsonInputDeserializerSpec extends FlatSpec with Matchers with Supportive {
  val configPath = getClass.getClassLoader.getResource("serving").getPath + "/config-test.yaml"

  val configParser = new ConfigParser(configPath)
  "read json string" should "work" in {
    val mapper = new ObjectMapper()
    val module = new SimpleModule()
    module.addDeserializer(classOf[Activity], new serialization.JsonInputDeserializer())
    mapper.registerModule(module)

    val jsonStr = """{
  "instances" : [ {
    "intTensor" : [ 7756, 9549, 1094, 9808, 4959, 3831, 3926, 6578, 1870, 1741 ],
    "floatTensor" : [ 0.6804766, 0.30136853, 0.17394465, 0.44770062, 0.20275897 ],
    "intTensor2" : [ [ 1, 2 ], [ 3, 4 ], [ 5, 6 ] ],
    "floatTensor2" : [ [ [ 0.2, 0.3 ], [ 0.5, 0.6 ] ], [ [ 0.2, 0.3 ], [ 0.5, 0.6 ] ] ],
    "intScalar" : 12345,
    "floatScalar" : 3.14159
  } ]
}"""
    val tinyJsonStr = """{
  "instances" : [ {
    "intScalar" : 12345
  } ]
}"""

    timing("decode")() {
      (0 to 100).foreach(_ => {

        timing("decode once")() {
          mapper.readValue(jsonStr, classOf[Activity])
        }
        timing("decode tiny string")() {
          mapper.readValue(tinyJsonStr, classOf[Activity])
        }
      })

    }
    val a = mapper.readValue(jsonStr, classOf[Activity])
    val b = mapper.readValue(tinyJsonStr, classOf[Activity])
    a
  }
  "read dien string" should "work" in {
    val mapper = new ObjectMapper()
    val module = new SimpleModule()
    module.addDeserializer(classOf[Activity], new serialization.JsonInputDeserializer())
    mapper.registerModule(module)
    val jsonStr = TestUtils.getStrFromResourceFile("dien_json_str.json")
    val a = mapper.readValue(jsonStr, classOf[Activity])
    a
  }
}

redpajama_set_name: RedPajamaGithub


text:
/* ** GENEREATED FILE - DO NOT MODIFY ** */
package com.wilutions.mslib.uccollaborationlib;
import com.wilutions.com.*;

/**
 * IModalityDictionary.
 * IModalityDictionary Interface
 */
@CoInterface(guid="{ED5040FA-8F8F-4876-BF6D-9C62F5EFFD5B}")
public interface IModalityDictionary extends IDispatch {
  static boolean __typelib__loaded = __TypeLib.load();
  @DeclDISPID(1610743808)  public Integer getCount() throws ComException;
  @DeclDISPID(0)  public IModality getItem(final ModalityTypes _modalityType) throws ComException;
  @DeclDISPID(1610743810)  public ModalityTypes[] getKeys() throws ComException;
  @DeclDISPID(1610743811)  public IModality[] getValues() throws ComException;
  @DeclDISPID(1610743812)  public Boolean TryGetValue(final ModalityTypes _modalityType, final ByRef<IModality> _itemValue) throws ComException;
  @DeclDISPID(1610743813)  public ModalityTypes GetKeyAt(final Integer _index) throws ComException;
  @DeclDISPID(1610743814)  public IModality GetValueAt(final Integer _index) throws ComException;
  @DeclDISPID(1610743815)  public Boolean ContainsKey(final ModalityTypes _modalityType) throws ComException;
}


text:
export RBENV_ROOT=/usr/local/rbenv
export PATH="$RBENV_ROOT/bin:$PATH"
eval "$(rbenv init -)"

export PATH="/usr/local/phpenv/bin:$PATH"
eval "$(phpenv init -)"


text:
// Copyright (c) Microsoft Corporation. All rights reserved.
// Licensed under the MIT License.
// Code generated by Microsoft (R) AutoRest Code Generator.

package com.azure.resourcemanager.datamigration.implementation;

import com.azure.core.annotation.BodyParam;
import com.azure.core.annotation.Delete;
import com.azure.core.annotation.ExpectedResponses;
import com.azure.core.annotation.Get;
import com.azure.core.annotation.HeaderParam;
import com.azure.core.annotation.Headers;
import com.azure.core.annotation.Host;
import com.azure.core.annotation.HostParam;
import com.azure.core.annotation.Patch;
import com.azure.core.annotation.PathParam;
import com.azure.core.annotation.Put;
import com.azure.core.annotation.QueryParam;
import com.azure.core.annotation.ReturnType;
import com.azure.core.annotation.ServiceInterface;
import com.azure.core.annotation.ServiceMethod;
import com.azure.core.annotation.UnexpectedResponseExceptionType;
import com.azure.core.http.rest.PagedFlux;
import com.azure.core.http.rest.PagedIterable;
import com.azure.core.http.rest.PagedResponse;
import com.azure.core.http.rest.PagedResponseBase;
import com.azure.core.http.rest.Response;
import com.azure.core.http.rest.RestProxy;
import com.azure.core.management.exception.ManagementException;
import com.azure.core.util.Context;
import com.azure.core.util.FluxUtil;
import com.azure.core.util.logging.ClientLogger;
import com.azure.resourcemanager.datamigration.fluent.ProjectsClient;
import com.azure.resourcemanager.datamigration.fluent.models.ProjectInner;
import com.azure.resourcemanager.datamigration.models.ProjectList;
import reactor.core.publisher.Mono;

/** An instance of this class provides access to all the operations defined in ProjectsClient. */
public final class ProjectsClientImpl implements ProjectsClient {
    private final ClientLogger logger = new ClientLogger(ProjectsClientImpl.class);

    /** The proxy service used to perform REST calls. */
    private final ProjectsService service;

    /** The service client containing this operation class. */
    private final DataMigrationManagementClientImpl client;

    /**
     * Initializes an instance of ProjectsClientImpl.
     *
     * @param client the instance of the service client containing this operation class.
     */
    ProjectsClientImpl(DataMigrationManagementClientImpl client) {
        this.service = RestProxy.create(ProjectsService.class, client.getHttpPipeline(), client.getSerializerAdapter());
        this.client = client;
    }

    /**
     * The interface defining all the services for DataMigrationManagementClientProjects to be used by the proxy service
     * to perform REST calls.
     */
    @Host("{$host}")
    @ServiceInterface(name = "DataMigrationManagem")
    private interface ProjectsService {
        @Headers({"Content-Type: application/json"})
        @Get(
            "/subscriptions/{subscriptionId}/resourceGroups/{groupName}/providers/Microsoft.DataMigration/services"
                + "/{serviceName}/projects")
        @ExpectedResponses({200})
        @UnexpectedResponseExceptionType(ManagementException.class)
        Mono<Response<ProjectList>> listByResourceGroup(
            @HostParam("$host") String endpoint,
            @PathParam("subscriptionId") String subscriptionId,
            @PathParam("groupName") String groupName,
            @PathParam("serviceName") String serviceName,
            @QueryParam("api-version") String apiVersion,
            @HeaderParam("Accept") String accept,
            Context context);

        @Headers({"Content-Type: application/json"})
        @Put(
            "/subscriptions/{subscriptionId}/resourceGroups/{groupName}/providers/Microsoft.DataMigration/services"
                + "/{serviceName}/projects/{projectName}")
        @ExpectedResponses({200, 201})
        @UnexpectedResponseExceptionType(ManagementException.class)
        Mono<Response<ProjectInner>> createOrUpdate(
            @HostParam("$host") String endpoint,
            @PathParam("subscriptionId") String subscriptionId,
            @PathParam("groupName") String groupName,
            @PathParam("serviceName") String serviceName,
            @PathParam("projectName") String projectName,
            @QueryParam("api-version") String apiVersion,
            @BodyParam("application/json") ProjectInner parameters,
            @HeaderParam("Accept") String accept,
            Context context);

        @Headers({"Content-Type: application/json"})
        @Get(
            "/subscriptions/{subscriptionId}/resourceGroups/{groupName}/providers/Microsoft.DataMigration/services"
                + "/{serviceName}/projects/{projectName}")
        @ExpectedResponses({200})
        @UnexpectedResponseExceptionType(ManagementException.class)
        Mono<Response<ProjectInner>> get(
            @HostParam("$host") String endpoint,
            @PathParam("subscriptionId") String subscriptionId,
            @PathParam("groupName") String groupName,
            @PathParam("serviceName") String serviceName,
            @PathParam("projectName") String projectName,
            @QueryParam("api-version") String apiVersion,
            @HeaderParam("Accept") String accept,
            Context context);

        @Headers({"Content-Type: application/json"})
        @Delete(
            "/subscriptions/{subscriptionId}/resourceGroups/{groupName}/providers/Microsoft.DataMigration/services"
                + "/{serviceName}/projects/{projectName}")
        @ExpectedResponses({200, 204})
        @UnexpectedResponseExceptionType(ManagementException.class)
        Mono<Response<Void>> delete(
            @HostParam("$host") String endpoint,
            @PathParam("subscriptionId") String subscriptionId,
            @PathParam("groupName") String groupName,
            @PathParam("serviceName") String serviceName,
            @PathParam("projectName") String projectName,
            @QueryParam("api-version") String apiVersion,
            @QueryParam("deleteRunningTasks") Boolean deleteRunningTasks,
            @HeaderParam("Accept") String accept,
            Context context);

        @Headers({"Content-Type: application/json"})
        @Patch(
            "/subscriptions/{subscriptionId}/resourceGroups/{groupName}/providers/Microsoft.DataMigration/services"
                + "/{serviceName}/projects/{projectName}")
        @ExpectedResponses({200})
        @UnexpectedResponseExceptionType(ManagementException.class)
        Mono<Response<ProjectInner>> update(
            @HostParam("$host") String endpoint,
            @PathParam("subscriptionId") String subscriptionId,
            @PathParam("groupName") String groupName,
            @PathParam("serviceName") String serviceName,
            @PathParam("projectName") String projectName,
            @QueryParam("api-version") String apiVersion,
            @BodyParam("application/json") ProjectInner parameters,
            @HeaderParam("Accept") String accept,
            Context context);

        @Headers({"Content-Type: application/json"})
        @Get("{nextLink}")
        @ExpectedResponses({200})
        @UnexpectedResponseExceptionType(ManagementException.class)
        Mono<Response<ProjectList>> listByResourceGroupNext(
            @PathParam(value = "nextLink", encoded = true) String nextLink,
            @HostParam("$host") String endpoint,
            @HeaderParam("Accept") String accept,
            Context context);
    }

    /**
     * The project resource is a nested resource representing a stored migration project. This method returns a list of
     * projects owned by a service resource.
     *
     * @param groupName Name of the resource group.
     * @param serviceName Name of the service.
     * @throws IllegalArgumentException thrown if parameters fail the validation.
     * @throws ManagementException thrown if the request is rejected by server.
     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
     * @return oData page of project resources.
     */
    @ServiceMethod(returns = ReturnType.SINGLE)
    private Mono<PagedResponse<ProjectInner>> listByResourceGroupSinglePageAsync(String groupName, String serviceName) {
        if (this.client.getEndpoint() == null) {
            return Mono
                .error(
                    new IllegalArgumentException(
                        "Parameter this.client.getEndpoint() is required and cannot be null."));
        }
        if (this.client.getSubscriptionId() == null) {
            return Mono
                .error(
                    new IllegalArgumentException(
                        "Parameter this.client.getSubscriptionId() is required and cannot be null."));
        }
        if (groupName == null) {
            return Mono.error(new IllegalArgumentException("Parameter groupName is required and cannot be null."));
        }
        if (serviceName == null) {
            return Mono.error(new IllegalArgumentException("Parameter serviceName is required and cannot be null."));
        }
        final String accept = "application/json";
        return FluxUtil
            .withContext(
                context ->
                    service
                        .listByResourceGroup(
                            this.client.getEndpoint(),
                            this.client.getSubscriptionId(),
                            groupName,
                            serviceName,
                            this.client.getApiVersion(),
                            accept,
                            context))
            .<PagedResponse<ProjectInner>>map(
                res ->
                    new PagedResponseBase<>(
                        res.getRequest(),
                        res.getStatusCode(),
                        res.getHeaders(),
                        res.getValue().value(),
                        res.getValue().nextLink(),
                        null))
            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
    }

    /**
     * The project resource is a nested resource representing a stored migration project. This method returns a list of
     * projects owned by a service resource.
     *
     * @param groupName Name of the resource group.
     * @param serviceName Name of the service.
     * @param context The context to associate with this operation.
     * @throws IllegalArgumentException thrown if parameters fail the validation.
     * @throws ManagementException thrown if the request is rejected by server.
     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
     * @return oData page of project resources.
     */
    @ServiceMethod(returns = ReturnType.SINGLE)
    private Mono<PagedResponse<ProjectInner>> listByResourceGroupSinglePageAsync(
        String groupName, String serviceName, Context context) {
        if (this.client.getEndpoint() == null) {
            return Mono
                .error(
                    new IllegalArgumentException(
                        "Parameter this.client.getEndpoint() is required and cannot be null."));
        }
        if (this.client.getSubscriptionId() == null) {
            return Mono
                .error(
                    new IllegalArgumentException(
                        "Parameter this.client.getSubscriptionId() is required and cannot be null."));
        }
        if (groupName == null) {
            return Mono.error(new IllegalArgumentException("Parameter groupName is required and cannot be null."));
        }
        if (serviceName == null) {
            return Mono.error(new IllegalArgumentException("Parameter serviceName is required and cannot be null."));
        }
        final String accept = "application/json";
        context = this.client.mergeContext(context);
        return service
            .listByResourceGroup(
                this.client.getEndpoint(),
                this.client.getSubscriptionId(),
                groupName,
                serviceName,
                this.client.getApiVersion(),
                accept,
                context)
            .map(
                res ->
                    new PagedResponseBase<>(
                        res.getRequest(),
                        res.getStatusCode(),
                        res.getHeaders(),
                        res.getValue().value(),
                        res.getValue().nextLink(),
                        null));
    }

    /**
     * The project resource is a nested resource representing a stored migration project. This method returns a list of
     * projects owned by a service resource.
     *
     * @param groupName Name of the resource group.
     * @param serviceName Name of the service.
     * @throws IllegalArgumentException thrown if parameters fail the validation.
     * @throws ManagementException thrown if the request is rejected by server.
     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
     * @return oData page of project resources.
     */
    @ServiceMethod(returns = ReturnType.COLLECTION)
    private PagedFlux<ProjectInner> listByResourceGroupAsync(String groupName, String serviceName) {
        return new PagedFlux<>(
            () -> listByResourceGroupSinglePageAsync(groupName, serviceName),
            nextLink -> listByResourceGroupNextSinglePageAsync(nextLink));
    }

    /**
     * The project resource is a nested resource representing a stored migration project. This method returns a list of
     * projects owned by a service resource.
     *
     * @param groupName Name of the resource group.
     * @param serviceName Name of the service.
     * @param context The context to associate with this operation.
     * @throws IllegalArgumentException thrown if parameters fail the validation.
     * @throws ManagementException thrown if the request is rejected by server.
     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
     * @return oData page of project resources.
     */
    @ServiceMethod(returns = ReturnType.COLLECTION)
    private PagedFlux<ProjectInner> listByResourceGroupAsync(String groupName, String serviceName, Context context) {
        return new PagedFlux<>(
            () -> listByResourceGroupSinglePageAsync(groupName, serviceName, context),
            nextLink -> listByResourceGroupNextSinglePageAsync(nextLink, context));
    }

    /**
     * The project resource is a nested resource representing a stored migration project. This method returns a list of
     * projects owned by a service resource.
     *
     * @param groupName Name of the resource group.
     * @param serviceName Name of the service.
     * @throws IllegalArgumentException thrown if parameters fail the validation.
     * @throws ManagementException thrown if the request is rejected by server.
     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
     * @return oData page of project resources.
     */
    @ServiceMethod(returns = ReturnType.COLLECTION)
    public PagedIterable<ProjectInner> listByResourceGroup(String groupName, String serviceName) {
        return new PagedIterable<>(listByResourceGroupAsync(groupName, serviceName));
    }

    /**
     * The project resource is a nested resource representing a stored migration project. This method returns a list of
     * projects owned by a service resource.
     *
     * @param groupName Name of the resource group.
     * @param serviceName Name of the service.
     * @param context The context to associate with this operation.
     * @throws IllegalArgumentException thrown if parameters fail the validation.
     * @throws ManagementException thrown if the request is rejected by server.
     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
     * @return oData page of project resources.
     */
    @ServiceMethod(returns = ReturnType.COLLECTION)
    public PagedIterable<ProjectInner> listByResourceGroup(String groupName, String serviceName, Context context) {
        return new PagedIterable<>(listByResourceGroupAsync(groupName, serviceName, context));
    }

    /**
     * The project resource is a nested resource representing a stored migration project. The PUT method creates a new
     * project or updates an existing one.
     *
     * @param groupName Name of the resource group.
     * @param serviceName Name of the service.
     * @param projectName Name of the project.
     * @param parameters Information about the project.
     * @throws IllegalArgumentException thrown if parameters fail the validation.
     * @throws ManagementException thrown if the request is rejected by server.
     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
     * @return a project resource.
     */
    @ServiceMethod(returns = ReturnType.SINGLE)
    private Mono<Response<ProjectInner>> createOrUpdateWithResponseAsync(
        String groupName, String serviceName, String projectName, ProjectInner parameters) {
        if (this.client.getEndpoint() == null) {
            return Mono
                .error(
                    new IllegalArgumentException(
                        "Parameter this.client.getEndpoint() is required and cannot be null."));
        }
        if (this.client.getSubscriptionId() == null) {
            return Mono
                .error(
                    new IllegalArgumentException(
                        "Parameter this.client.getSubscriptionId() is required and cannot be null."));
        }
        if (groupName == null) {
            return Mono.error(new IllegalArgumentException("Parameter groupName is required and cannot be null."));
        }
        if (serviceName == null) {
            return Mono.error(new IllegalArgumentException("Parameter serviceName is required and cannot be null."));
        }
        if (projectName == null) {
            return Mono.error(new IllegalArgumentException("Parameter projectName is required and cannot be null."));
        }
        if (parameters == null) {
            return Mono.error(new IllegalArgumentException("Parameter parameters is required and cannot be null."));
        } else {
            parameters.validate();
        }
        final String accept = "application/json";
        return FluxUtil
            .withContext(
                context ->
                    service
                        .createOrUpdate(
                            this.client.getEndpoint(),
                            this.client.getSubscriptionId(),
                            groupName,
                            serviceName,
                            projectName,
                            this.client.getApiVersion(),
                            parameters,
                            accept,
                            context))
            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
    }

    /**
     * The project resource is a nested resource representing a stored migration project. The PUT method creates a new
     * project or updates an existing one.
     *
     * @param groupName Name of the resource group.
     * @param serviceName Name of the service.
     * @param projectName Name of the project.
     * @param parameters Information about the project.
     * @param context The context to associate with this operation.
     * @throws IllegalArgumentException thrown if parameters fail the validation.
     * @throws ManagementException thrown if the request is rejected by server.
     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
     * @return a project resource.
     */
    @ServiceMethod(returns = ReturnType.SINGLE)
    private Mono<Response<ProjectInner>> createOrUpdateWithResponseAsync(
        String groupName, String serviceName, String projectName, ProjectInner parameters, Context context) {
        if (this.client.getEndpoint() == null) {
            return Mono
                .error(
                    new IllegalArgumentException(
                        "Parameter this.client.getEndpoint() is required and cannot be null."));
        }
        if (this.client.getSubscriptionId() == null) {
            return Mono
                .error(
                    new IllegalArgumentException(
                        "Parameter this.client.getSubscriptionId() is required and cannot be null."));
        }
        if (groupName == null) {
            return Mono.error(new IllegalArgumentException("Parameter groupName is required and cannot be null."));
        }
        if (serviceName == null) {
            return Mono.error(new IllegalArgumentException("Parameter serviceName is required and cannot be null."));
        }
        if (projectName == null) {
            return Mono.error(new IllegalArgumentException("Parameter projectName is required and cannot be null."));
        }
        if (parameters == null) {
            return Mono.error(new IllegalArgumentException("Parameter parameters is required and cannot be null."));
        } else {
            parameters.validate();
        }
        final String accept = "application/json";
        context = this.client.mergeContext(context);
        return service
            .createOrUpdate(
                this.client.getEndpoint(),
                this.client.getSubscriptionId(),
                groupName,
                serviceName,
                projectName,
                this.client.getApiVersion(),
                parameters,
                accept,
                context);
    }

    /**
     * The project resource is a nested resource representing a stored migration project. The PUT method creates a new
     * project or updates an existing one.
     *
     * @param groupName Name of the resource group.
     * @param serviceName Name of the service.
     * @param projectName Name of the project.
     * @param parameters Information about the project.
     * @throws IllegalArgumentException thrown if parameters fail the validation.
     * @throws ManagementException thrown if the request is rejected by server.
     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
     * @return a project resource.
     */
    @ServiceMethod(returns = ReturnType.SINGLE)
    private Mono<ProjectInner> createOrUpdateAsync(
        String groupName, String serviceName, String projectName, ProjectInner parameters) {
        return createOrUpdateWithResponseAsync(groupName, serviceName, projectName, parameters)
            .flatMap(
                (Response<ProjectInner> res) -> {
                    if (res.getValue() != null) {
                        return Mono.just(res.getValue());
                    } else {
                        return Mono.empty();
                    }
                });
    }

    /**
     * The project resource is a nested resource representing a stored migration project. The PUT method creates a new
     * project or updates an existing one.
     *
     * @param groupName Name of the resource group.
     * @param serviceName Name of the service.
     * @param projectName Name of the project.
     * @param parameters Information about the project.
     * @throws IllegalArgumentException thrown if parameters fail the validation.
     * @throws ManagementException thrown if the request is rejected by server.
     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
     * @return a project resource.
     */
    @ServiceMethod(returns = ReturnType.SINGLE)
    public ProjectInner createOrUpdate(
        String groupName, String serviceName, String projectName, ProjectInner parameters) {
        return createOrUpdateAsync(groupName, serviceName, projectName, parameters).block();
    }

    /**
     * The project resource is a nested resource representing a stored migration project. The PUT method creates a new
     * project or updates an existing one.
     *
     * @param groupName Name of the resource group.
     * @param serviceName Name of the service.
     * @param projectName Name of the project.
     * @param parameters Information about the project.
     * @param context The context to associate with this operation.
     * @throws IllegalArgumentException thrown if parameters fail the validation.
     * @throws ManagementException thrown if the request is rejected by server.
     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
     * @return a project resource.
     */
    @ServiceMethod(returns = ReturnType.SINGLE)
    public Response<ProjectInner> createOrUpdateWithResponse(
        String groupName, String serviceName, String projectName, ProjectInner parameters, Context context) {
        return createOrUpdateWithResponseAsync(groupName, serviceName, projectName, parameters, context).block();
    }

    /**
     * The project resource is a nested resource representing a stored migration project. The GET method retrieves
     * information about a project.
     *
     * @param groupName Name of the resource group.
     * @param serviceName Name of the service.
     * @param projectName Name of the project.
     * @throws IllegalArgumentException thrown if parameters fail the validation.
     * @throws ManagementException thrown if the request is rejected by server.
     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
     * @return a project resource.
     */
    @ServiceMethod(returns = ReturnType.SINGLE)
    private Mono<Response<ProjectInner>> getWithResponseAsync(
        String groupName, String serviceName, String projectName) {
        if (this.client.getEndpoint() == null) {
            return Mono
                .error(
                    new IllegalArgumentException(
                        "Parameter this.client.getEndpoint() is required and cannot be null."));
        }
        if (this.client.getSubscriptionId() == null) {
            return Mono
                .error(
                    new IllegalArgumentException(
                        "Parameter this.client.getSubscriptionId() is required and cannot be null."));
        }
        if (groupName == null) {
            return Mono.error(new IllegalArgumentException("Parameter groupName is required and cannot be null."));
        }
        if (serviceName == null) {
            return Mono.error(new IllegalArgumentException("Parameter serviceName is required and cannot be null."));
        }
        if (projectName == null) {
            return Mono.error(new IllegalArgumentException("Parameter projectName is required and cannot be null."));
        }
        final String accept = "application/json";
        return FluxUtil
            .withContext(
                context ->
                    service
                        .get(
                            this.client.getEndpoint(),
                            this.client.getSubscriptionId(),
                            groupName,
                            serviceName,
                            projectName,
                            this.client.getApiVersion(),
                            accept,
                            context))
            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
    }

    /**
     * The project resource is a nested resource representing a stored migration project. The GET method retrieves
     * information about a project.
     *
     * @param groupName Name of the resource group.
     * @param serviceName Name of the service.
     * @param projectName Name of the project.
     * @param context The context to associate with this operation.
     * @throws IllegalArgumentException thrown if parameters fail the validation.
     * @throws ManagementException thrown if the request is rejected by server.
     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
     * @return a project resource.
     */
    @ServiceMethod(returns = ReturnType.SINGLE)
    private Mono<Response<ProjectInner>> getWithResponseAsync(
        String groupName, String serviceName, String projectName, Context context) {
        if (this.client.getEndpoint() == null) {
            return Mono
                .error(
                    new IllegalArgumentException(
                        "Parameter this.client.getEndpoint() is required and cannot be null."));
        }
        if (this.client.getSubscriptionId() == null) {
            return Mono
                .error(
                    new IllegalArgumentException(
                        "Parameter this.client.getSubscriptionId() is required and cannot be null."));
        }
        if (groupName == null) {
            return Mono.error(new IllegalArgumentException("Parameter groupName is required and cannot be null."));
        }
        if (serviceName == null) {
            return Mono.error(new IllegalArgumentException("Parameter serviceName is required and cannot be null."));
        }
        if (projectName == null) {
            return Mono.error(new IllegalArgumentException("Parameter projectName is required and cannot be null."));
        }
        final String accept = "application/json";
        context = this.client.mergeContext(context);
        return service
            .get(
                this.client.getEndpoint(),
                this.client.getSubscriptionId(),
                groupName,
                serviceName,
                projectName,
                this.client.getApiVersion(),
                accept,
                context);
    }

    /**
     * The project resource is a nested resource representing a stored migration project. The GET method retrieves
     * information about a project.
     *
     * @param groupName Name of the resource group.
     * @param serviceName Name of the service.
     * @param projectName Name of the project.
     * @throws IllegalArgumentException thrown if parameters fail the validation.
     * @throws ManagementException thrown if the request is rejected by server.
     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
     * @return a project resource.
     */
    @ServiceMethod(returns = ReturnType.SINGLE)
    private Mono<ProjectInner> getAsync(String groupName, String serviceName, String projectName) {
        return getWithResponseAsync(groupName, serviceName, projectName)
            .flatMap(
                (Response<ProjectInner> res) -> {
                    if (res.getValue() != null) {
                        return Mono.just(res.getValue());
                    } else {
                        return Mono.empty();
                    }
                });
    }

    /**
     * The project resource is a nested resource representing a stored migration project. The GET method retrieves
     * information about a project.
     *
     * @param groupName Name of the resource group.
     * @param serviceName Name of the service.
     * @param projectName Name of the project.
     * @throws IllegalArgumentException thrown if parameters fail the validation.
     * @throws ManagementException thrown if the request is rejected by server.
     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
     * @return a project resource.
     */
    @ServiceMethod(returns = ReturnType.SINGLE)
    public ProjectInner get(String groupName, String serviceName, String projectName) {
        return getAsync(groupName, serviceName, projectName).block();
    }

    /**
     * The project resource is a nested resource representing a stored migration project. The GET method retrieves
     * information about a project.
     *
     * @param groupName Name of the resource group.
     * @param serviceName Name of the service.
     * @param projectName Name of the project.
     * @param context The context to associate with this operation.
     * @throws IllegalArgumentException thrown if parameters fail the validation.
     * @throws ManagementException thrown if the request is rejected by server.
     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
     * @return a project resource.
     */
    @ServiceMethod(returns = ReturnType.SINGLE)
    public Response<ProjectInner> getWithResponse(
        String groupName, String serviceName, String projectName, Context context) {
        return getWithResponseAsync(groupName, serviceName, projectName, context).block();
    }

    /**
     * The project resource is a nested resource representing a stored migration project. The DELETE method deletes a
     * project.
     *
     * @param groupName Name of the resource group.
     * @param serviceName Name of the service.
     * @param projectName Name of the project.
     * @param deleteRunningTasks Delete the resource even if it contains running tasks.
     * @throws IllegalArgumentException thrown if parameters fail the validation.
     * @throws ManagementException thrown if the request is rejected by server.
     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
     * @return the completion.
     */
    @ServiceMethod(returns = ReturnType.SINGLE)
    private Mono<Response<Void>> deleteWithResponseAsync(
        String groupName, String serviceName, String projectName, Boolean deleteRunningTasks) {
        if (this.client.getEndpoint() == null) {
            return Mono
                .error(
                    new IllegalArgumentException(
                        "Parameter this.client.getEndpoint() is required and cannot be null."));
        }
        if (this.client.getSubscriptionId() == null) {
            return Mono
                .error(
                    new IllegalArgumentException(
                        "Parameter this.client.getSubscriptionId() is required and cannot be null."));
        }
        if (groupName == null) {
            return Mono.error(new IllegalArgumentException("Parameter groupName is required and cannot be null."));
        }
        if (serviceName == null) {
            return Mono.error(new IllegalArgumentException("Parameter serviceName is required and cannot be null."));
        }
        if (projectName == null) {
            return Mono.error(new IllegalArgumentException("Parameter projectName is required and cannot be null."));
        }
        final String accept = "application/json";
        return FluxUtil
            .withContext(
                context ->
                    service
                        .delete(
                            this.client.getEndpoint(),
                            this.client.getSubscriptionId(),
                            groupName,
                            serviceName,
                            projectName,
                            this.client.getApiVersion(),
                            deleteRunningTasks,
                            accept,
                            context))
            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
    }

    /**
     * The project resource is a nested resource representing a stored migration project. The DELETE method deletes a
     * project.
     *
     * @param groupName Name of the resource group.
     * @param serviceName Name of the service.
     * @param projectName Name of the project.
     * @param deleteRunningTasks Delete the resource even if it contains running tasks.
     * @param context The context to associate with this operation.
     * @throws IllegalArgumentException thrown if parameters fail the validation.
     * @throws ManagementException thrown if the request is rejected by server.
     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
     * @return the completion.
     */
    @ServiceMethod(returns = ReturnType.SINGLE)
    private Mono<Response<Void>> deleteWithResponseAsync(
        String groupName, String serviceName, String projectName, Boolean deleteRunningTasks, Context context) {
        if (this.client.getEndpoint() == null) {
            return Mono
                .error(
                    new IllegalArgumentException(
                        "Parameter this.client.getEndpoint() is required and cannot be null."));
        }
        if (this.client.getSubscriptionId() == null) {
            return Mono
                .error(
                    new IllegalArgumentException(
                        "Parameter this.client.getSubscriptionId() is required and cannot be null."));
        }
        if (groupName == null) {
            return Mono.error(new IllegalArgumentException("Parameter groupName is required and cannot be null."));
        }
        if (serviceName == null) {
            return Mono.error(new IllegalArgumentException("Parameter serviceName is required and cannot be null."));
        }
        if (projectName == null) {
            return Mono.error(new IllegalArgumentException("Parameter projectName is required and cannot be null."));
        }
        final String accept = "application/json";
        context = this.client.mergeContext(context);
        return service
            .delete(
                this.client.getEndpoint(),
                this.client.getSubscriptionId(),
                groupName,
                serviceName,
                projectName,
                this.client.getApiVersion(),
                deleteRunningTasks,
                accept,
                context);
    }

    /**
     * The project resource is a nested resource representing a stored migration project. The DELETE method deletes a
     * project.
     *
     * @param groupName Name of the resource group.
     * @param serviceName Name of the service.
     * @param projectName Name of the project.
     * @param deleteRunningTasks Delete the resource even if it contains running tasks.
     * @throws IllegalArgumentException thrown if parameters fail the validation.
     * @throws ManagementException thrown if the request is rejected by server.
     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
     * @return the completion.
     */
    @ServiceMethod(returns = ReturnType.SINGLE)
    private Mono<Void> deleteAsync(
        String groupName, String serviceName, String projectName, Boolean deleteRunningTasks) {
        return deleteWithResponseAsync(groupName, serviceName, projectName, deleteRunningTasks)
            .flatMap((Response<Void> res) -> Mono.empty());
    }

    /**
     * The project resource is a nested resource representing a stored migration project. The DELETE method deletes a
     * project.
     *
     * @param groupName Name of the resource group.
     * @param serviceName Name of the service.
     * @param projectName Name of the project.
     * @throws IllegalArgumentException thrown if parameters fail the validation.
     * @throws ManagementException thrown if the request is rejected by server.
     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
     * @return the completion.
     */
    @ServiceMethod(returns = ReturnType.SINGLE)
    private Mono<Void> deleteAsync(String groupName, String serviceName, String projectName) {
        final Boolean deleteRunningTasks = null;
        return deleteWithResponseAsync(groupName, serviceName, projectName, deleteRunningTasks)
            .flatMap((Response<Void> res) -> Mono.empty());
    }

    /**
     * The project resource is a nested resource representing a stored migration project. The DELETE method deletes a
     * project.
     *
     * @param groupName Name of the resource group.
     * @param serviceName Name of the service.
     * @param projectName Name of the project.
     * @throws IllegalArgumentException thrown if parameters fail the validation.
     * @throws ManagementException thrown if the request is rejected by server.
     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
     */
    @ServiceMethod(returns = ReturnType.SINGLE)
    public void delete(String groupName, String serviceName, String projectName) {
        final Boolean deleteRunningTasks = null;
        deleteAsync(groupName, serviceName, projectName, deleteRunningTasks).block();
    }

    /**
     * The project resource is a nested resource representing a stored migration project. The DELETE method deletes a
     * project.
     *
     * @param groupName Name of the resource group.
     * @param serviceName Name of the service.
     * @param projectName Name of the project.
     * @param deleteRunningTasks Delete the resource even if it contains running tasks.
     * @param context The context to associate with this operation.
     * @throws IllegalArgumentException thrown if parameters fail the validation.
     * @throws ManagementException thrown if the request is rejected by server.
     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
     * @return the response.
     */
    @ServiceMethod(returns = ReturnType.SINGLE)
    public Response<Void> deleteWithResponse(
        String groupName, String serviceName, String projectName, Boolean deleteRunningTasks, Context context) {
        return deleteWithResponseAsync(groupName, serviceName, projectName, deleteRunningTasks, context).block();
    }

    /**
     * The project resource is a nested resource representing a stored migration project. The PATCH method updates an
     * existing project.
     *
     * @param groupName Name of the resource group.
     * @param serviceName Name of the service.
     * @param projectName Name of the project.
     * @param parameters Information about the project.
     * @throws IllegalArgumentException thrown if parameters fail the validation.
     * @throws ManagementException thrown if the request is rejected by server.
     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
     * @return a project resource.
     */
    @ServiceMethod(returns = ReturnType.SINGLE)
    private Mono<Response<ProjectInner>> updateWithResponseAsync(
        String groupName, String serviceName, String projectName, ProjectInner parameters) {
        if (this.client.getEndpoint() == null) {
            return Mono
                .error(
                    new IllegalArgumentException(
                        "Parameter this.client.getEndpoint() is required and cannot be null."));
        }
        if (this.client.getSubscriptionId() == null) {
            return Mono
                .error(
                    new IllegalArgumentException(
                        "Parameter this.client.getSubscriptionId() is required and cannot be null."));
        }
        if (groupName == null) {
            return Mono.error(new IllegalArgumentException("Parameter groupName is required and cannot be null."));
        }
        if (serviceName == null) {
            return Mono.error(new IllegalArgumentException("Parameter serviceName is required and cannot be null."));
        }
        if (projectName == null) {
            return Mono.error(new IllegalArgumentException("Parameter projectName is required and cannot be null."));
        }
        if (parameters == null) {
            return Mono.error(new IllegalArgumentException("Parameter parameters is required and cannot be null."));
        } else {
            parameters.validate();
        }
        final String accept = "application/json";
        return FluxUtil
            .withContext(
                context ->
                    service
                        .update(
                            this.client.getEndpoint(),
                            this.client.getSubscriptionId(),
                            groupName,
                            serviceName,
                            projectName,
                            this.client.getApiVersion(),
                            parameters,
                            accept,
                            context))
            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
    }

    /**
     * The project resource is a nested resource representing a stored migration project. The PATCH method updates an
     * existing project.
     *
     * @param groupName Name of the resource group.
     * @param serviceName Name of the service.
     * @param projectName Name of the project.
     * @param parameters Information about the project.
     * @param context The context to associate with this operation.
     * @throws IllegalArgumentException thrown if parameters fail the validation.
     * @throws ManagementException thrown if the request is rejected by server.
     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
     * @return a project resource.
     */
    @ServiceMethod(returns = ReturnType.SINGLE)
    private Mono<Response<ProjectInner>> updateWithResponseAsync(
        String groupName, String serviceName, String projectName, ProjectInner parameters, Context context) {
        if (this.client.getEndpoint() == null) {
            return Mono
                .error(
                    new IllegalArgumentException(
                        "Parameter this.client.getEndpoint() is required and cannot be null."));
        }
        if (this.client.getSubscriptionId() == null) {
            return Mono
                .error(
                    new IllegalArgumentException(
                        "Parameter this.client.getSubscriptionId() is required and cannot be null."));
        }
        if (groupName == null) {
            return Mono.error(new IllegalArgumentException("Parameter groupName is required and cannot be null."));
        }
        if (serviceName == null) {
            return Mono.error(new IllegalArgumentException("Parameter serviceName is required and cannot be null."));
        }
        if (projectName == null) {
            return Mono.error(new IllegalArgumentException("Parameter projectName is required and cannot be null."));
        }
        if (parameters == null) {
            return Mono.error(new IllegalArgumentException("Parameter parameters is required and cannot be null."));
        } else {
            parameters.validate();
        }
        final String accept = "application/json";
        context = this.client.mergeContext(context);
        return service
            .update(
                this.client.getEndpoint(),
                this.client.getSubscriptionId(),
                groupName,
                serviceName,
                projectName,
                this.client.getApiVersion(),
                parameters,
                accept,
                context);
    }

    /**
     * The project resource is a nested resource representing a stored migration project. The PATCH method updates an
     * existing project.
     *
     * @param groupName Name of the resource group.
     * @param serviceName Name of the service.
     * @param projectName Name of the project.
     * @param parameters Information about the project.
     * @throws IllegalArgumentException thrown if parameters fail the validation.
     * @throws ManagementException thrown if the request is rejected by server.
     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
     * @return a project resource.
     */
    @ServiceMethod(returns = ReturnType.SINGLE)
    private Mono<ProjectInner> updateAsync(
        String groupName, String serviceName, String projectName, ProjectInner parameters) {
        return updateWithResponseAsync(groupName, serviceName, projectName, parameters)
            .flatMap(
                (Response<ProjectInner> res) -> {
                    if (res.getValue() != null) {
                        return Mono.just(res.getValue());
                    } else {
                        return Mono.empty();
                    }
                });
    }

    /**
     * The project resource is a nested resource representing a stored migration project. The PATCH method updates an
     * existing project.
     *
     * @param groupName Name of the resource group.
     * @param serviceName Name of the service.
     * @param projectName Name of the project.
     * @param parameters Information about the project.
     * @throws IllegalArgumentException thrown if parameters fail the validation.
     * @throws ManagementException thrown if the request is rejected by server.
     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
     * @return a project resource.
     */
    @ServiceMethod(returns = ReturnType.SINGLE)
    public ProjectInner update(String groupName, String serviceName, String projectName, ProjectInner parameters) {
        return updateAsync(groupName, serviceName, projectName, parameters).block();
    }

    /**
     * The project resource is a nested resource representing a stored migration project. The PATCH method updates an
     * existing project.
     *
     * @param groupName Name of the resource group.
     * @param serviceName Name of the service.
     * @param projectName Name of the project.
     * @param parameters Information about the project.
     * @param context The context to associate with this operation.
     * @throws IllegalArgumentException thrown if parameters fail the validation.
     * @throws ManagementException thrown if the request is rejected by server.
     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
     * @return a project resource.
     */
    @ServiceMethod(returns = ReturnType.SINGLE)
    public Response<ProjectInner> updateWithResponse(
        String groupName, String serviceName, String projectName, ProjectInner parameters, Context context) {
        return updateWithResponseAsync(groupName, serviceName, projectName, parameters, context).block();
    }

    /**
     * Get the next page of items.
     *
     * @param nextLink The nextLink parameter.
     * @throws IllegalArgumentException thrown if parameters fail the validation.
     * @throws ManagementException thrown if the request is rejected by server.
     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
     * @return oData page of project resources.
     */
    @ServiceMethod(returns = ReturnType.SINGLE)
    private Mono<PagedResponse<ProjectInner>> listByResourceGroupNextSinglePageAsync(String nextLink) {
        if (nextLink == null) {
            return Mono.error(new IllegalArgumentException("Parameter nextLink is required and cannot be null."));
        }
        if (this.client.getEndpoint() == null) {
            return Mono
                .error(
                    new IllegalArgumentException(
                        "Parameter this.client.getEndpoint() is required and cannot be null."));
        }
        final String accept = "application/json";
        return FluxUtil
            .withContext(
                context -> service.listByResourceGroupNext(nextLink, this.client.getEndpoint(), accept, context))
            .<PagedResponse<ProjectInner>>map(
                res ->
                    new PagedResponseBase<>(
                        res.getRequest(),
                        res.getStatusCode(),
                        res.getHeaders(),
                        res.getValue().value(),
                        res.getValue().nextLink(),
                        null))
            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
    }

    /**
     * Get the next page of items.
     *
     * @param nextLink The nextLink parameter.
     * @param context The context to associate with this operation.
     * @throws IllegalArgumentException thrown if parameters fail the validation.
     * @throws ManagementException thrown if the request is rejected by server.
     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
     * @return oData page of project resources.
     */
    @ServiceMethod(returns = ReturnType.SINGLE)
    private Mono<PagedResponse<ProjectInner>> listByResourceGroupNextSinglePageAsync(String nextLink, Context context) {
        if (nextLink == null) {
            return Mono.error(new IllegalArgumentException("Parameter nextLink is required and cannot be null."));
        }
        if (this.client.getEndpoint() == null) {
            return Mono
                .error(
                    new IllegalArgumentException(
                        "Parameter this.client.getEndpoint() is required and cannot be null."));
        }
        final String accept = "application/json";
        context = this.client.mergeContext(context);
        return service
            .listByResourceGroupNext(nextLink, this.client.getEndpoint(), accept, context)
            .map(
                res ->
                    new PagedResponseBase<>(
                        res.getRequest(),
                        res.getStatusCode(),
                        res.getHeaders(),
                        res.getValue().value(),
                        res.getValue().nextLink(),
                        null));
    }
}


text:
package com.marvin.handlers.metrics;

import com.codahale.metrics.Meter;
import com.codahale.metrics.MetricRegistry;
import com.codahale.metrics.Timer;
import com.marvin.handlers.MarvinHandler;
import com.marvin.handlers.Request;
import com.marvin.handlers.Response;

import static com.codahale.metrics.MetricRegistry.name;

public class MeteringHandler extends MarvinHandler {

    private final MarvinHandler handler;
    private final Meter meter;
    private final Timer timer;

    public MeteringHandler(final MetricRegistry metricRegistry, final MarvinHandler handler) {
        this.handler = handler;
        meter = metricRegistry.meter(name(handler.getClass(), "meter"));
        timer = metricRegistry.timer(name(handler.getClass(), "timer"));
    }

    public Object process(final Request request, final Response response) throws Exception {
        final Timer.Context context = timer.time();
        try {
            meter.mark();
            return handler.process(request, response);
        }finally {
            context.stop();
        }
    }
}


text:
[CmdletBinding()]
param()

# Arrange.
. $PSScriptRoot\..\..\..\Tests\lib\Initialize-Test.ps1
$targetAzurePs = "4.1.0"
$input_workingDirectory = "C:\Users"
Register-Mock Get-VstsInput { "FilePath" } -- -Name ScriptType -Require
Register-Mock Get-VstsInput { "$PSScriptRoot/PerformsBasicFlow_TargetScript.ps1" } -- -Name ScriptPath
Register-Mock Get-VstsInput { $targetAzurePs } -- -Name TargetAzurePs
Register-Mock Get-VstsInput { 'arg1 arg2' } -- -Name ScriptArguments
Register-Mock Get-VstsInput { "continue" } -- -Name errorActionPreference
Register-Mock Get-VstsInput { $true } -- -Name FailOnStandardError
Register-Mock Get-VstsInput { $true } -- -Name pwsh -AsBool
Register-Mock Get-VstsInput { $input_workingDirectory } -- -Name workingDirectory -Require
Register-Mock Update-PSModulePathForHostedAgent
Register-Mock Get-Module
Register-Mock Initialize-AzModule
Register-Mock Get-VstsEndpoint { @{auth = @{ scheme = "ServicePrincipal" }} }
Register-Mock Remove-EndpointSecrets
Register-Mock Disconnect-AzureAndClearContext
Register-Mock Assert-VstsPath
Register-Mock Invoke-VstsTool { }
Register-Mock Expand-ModuleZip
Register-Mock Invoke-RestMethod
Register-Mock Save-Module

# Act.
$actual = & $PSScriptRoot\..\AzurePowerShell.ps1

Assert-WasCalled Invoke-VstsTool -Times 1
Assert-WasCalled Invoke-VstsTool -ArgumentsEvaluator {($args | ConvertTo-Json) -like '*C:\\Users*'}


text:
{-# LANGUAGE OverloadedStrings, RecursiveDo, ScopedTypeVariables, FlexibleContexts, TypeFamilies, ConstraintKinds #-}

module AWSFunction where

import Prelude hiding (mapM, mapM_, all, sequence)

import           Control.Monad hiding (mapM, mapM_, forM, forM_, sequence)
import qualified Data.Map                  as Map
import           Data.Monoid ((<>))
import           Data.Text (Text)
import qualified Data.Text                 as T
import qualified Data.Text.Read            as TR
import qualified Data.Maybe                as Maybe
import           Numeric (showFFloat)
import           Reflex
import           Reflex.Dom.Core

-----
-- AWS Related Function
-----

data AwsIcon = CF | DB | EC2 | EC | LS | RDS | R53 | S3 | VPC
  deriving (Eq, Show, Ord)

iconName :: AwsIcon -> T.Text
iconName awi =
  case awi of
    CF  -> "static/svg/AmazonCloudFront.png"
    DB  -> "static/svg/AmazonDynamoDB.png"
    EC2 -> "static/svg/AmazonEC2.png"
    EC  -> "static/svg/AmazonElasticCache.png"
    LS  -> "static/svg/AmazonLightsail.png"
    RDS -> "static/svg/AmazonRDS.png"
    R53 -> "static/svg/AmazonRoute53.png"
    S3  -> "static/svg/AmazonS3.png"
    VPC -> "static/svg/AmazonVPC.png"

foldTheCost :: (Num a, Reflex t) => Dynamic t a -> Dynamic t a -> Dynamic t (Dynamic t a)
foldTheCost x y = constDyn $ (+) <$> x <*> y

theDynCost :: Reflex t => [(Int, Dynamic t Text)] -> Int -> Dynamic t Text
theDynCost rightM key = Maybe.fromMaybe (constDyn $ T.pack "0") $ lookup key rightM

curSelect :: Reflex t => Dynamic t (Maybe AwsIcon) -> AwsIcon -> Dynamic t Bool
curSelect dA ic = demuxed (demux dA) (Just ic)

imgAttrs :: AwsIcon -> Map.Map T.Text T.Text
imgAttrs awi = ("src" =: (iconName awi)) <>
               ("width" =: "81") <>
	       ("height" =: "80")

idAttrs :: AwsIcon -> Map.Map T.Text T.Text
idAttrs awi = ("id" =: T.pack (show awi))

rightClassAttrs :: Reflex t => Dynamic t (Map.Map T.Text T.Text)
rightClassAttrs = constDyn ("class" =: "rightProp")

showAttrs :: Bool -> Map.Map T.Text T.Text
showAttrs b = "style" =: ("display: " <> display' b)
  where
    display' True = "inline-flex"
    display' _    = "none"

labelAttrs :: Bool -> Map.Map T.Text T.Text
labelAttrs b = "style" =: ("background-color: " <> color b)
  where
    color True = "hsla(171,100%,84%,1)"
    color _    = "transparent"

serviceButton :: (MonadWidget t m) => T.Text
                                   -> AwsIcon
				   -> Dynamic t (Map.Map T.Text T.Text)
				   -> Dynamic t T.Text
				   -> m (Event t AwsIcon)
serviceButton label icon dynAttrs dynCost = do
    (ev1,_) <- elDynAttr' "label" ((constDyn $ idAttrs icon) <> dynAttrs) $ do
            elAttr' "img" (imgAttrs icon) $ text ""
            el "h2" $ text label
	    let text1 = constDyn "Monthly Cost: $ "
            el "h4" $ dynText $ text1 <> dynCost
    return $ icon <$ (domEvent Click ev1)

lsRadioBtn :: (MonadWidget t m) =>  T.Text
			        -> Int
				-> m (Event t Int)
lsRadioBtn group rid = do
    ev <- elAttr "label" ("class" =: "lsRad") $ do
        (rb1, _) <- elAttr' "input" ("name" =: group <> "type" =: "radio" <> "value" =: T.pack (show rid))  blank
        lsClicked rid
        return $ domEvent Click rb1
    return $ rid <$ ev

lsClicked :: (MonadWidget t m) => Int -> m ()
lsClicked rid = case rid of
  1 -> do
        text "$ 5/Month"
	el "p" $ text "512 MB Memory"
	el "p" $ text "1 Core Processor"
	el "p" $ text "20 GB SSD Disk"
	el "p" $ text "1 TB Transfer"
        return ()
  2 -> do
        text "$ 10/Month"
	el "p" $ text "1 GB Memory"
	el "p" $ text "1 Core Processor"
	el "p" $ text "30 GB SSD Disk"
	el "p" $ text "2 TB Transfer"
        return ()
  3 -> do
        text "$ 20/Month"
	el "p" $ text "2 GB Memory"
	el "p" $ text "1 Core Processor"
	el "p" $ text "40 GB SSD Disk"
	el "p" $ text "3 TB Transfer"
        return ()
  4 -> do
        text "$ 40/Month"
	el "p" $ text " 4 GB Memory"
	el "p" $ text "2 Core Processor"
	el "p" $ text "60 GB SSD Disk"
	el "p" $ text "4 TB Transfer"
        return ()
  _ -> do
        text "$ 80/Month"
	el "p" $ text "8 GB Memory"
	el "p" $ text "2 Core Processor"
	el "p" $ text "80 GB SSD Disk"
	el "p" $ text "5 TB Transfer"
        return ()

turnToInt :: Num a => TR.Reader a -> T.Text -> a
turnToInt = (theValue .)
  where
    theValue (Right (v,_)) = v
    theValue (Left _)      = 0

readDouble :: T.Text -> Double
readDouble = turnToInt TR.double

showPrecise :: RealFloat a => a -> String
showPrecise x = showFFloat Nothing x ""

toDynText :: (Reflex t, Show a, RealFloat a) => Dynamic t a -> Dynamic t T.Text
toDynText = ((T.pack . showPrecise) <$>)

toText :: (Show a, RealFloat a) => a -> Text
toText = (T.pack . showPrecise)

ddUsage :: Map.Map Int T.Text
ddUsage = Map.fromList [(1,"Hours/Day"), (2, "Hours/Week"), (3, "Hours/Month")]

ddType :: Map.Map Int T.Text
ddType = Map.fromList [(1,"t2.micro"), (2, "t2.small"), (3, "t2.medium"), (4, "t2.large")]

ddNode :: Map.Map Int T.Text
ddNode = Map.fromList [(1,"t2.micro"), (2, "t2.small"), (3, "t2.medium")]

ddStorage :: Map.Map Int T.Text
ddStorage = Map.fromList [(1,"GB"), (2, "TB"), (3, "PB")]

ddPerMonth :: Map.Map Int T.Text
ddPerMonth = Map.fromList [(1,"Per Day"), (2, "Per Week"), (3, "Per Month")]

ddVolume :: Map.Map Int T.Text
ddVolume = Map.fromList [(1,"GB/Day"), (2, "GB/Week"), (3, "GB/Month"), (4, "TB/Month")]

ddDataSet :: Map.Map Int T.Text
ddDataSet = Map.fromList [(1,"GB"), (2, "TB")]

ddEngine :: Map.Map Int T.Text
ddEngine = Map.fromList [(1,"MariaDB"), (2, "PostgreSQL")]

ddDeploy :: Map.Map Int T.Text
ddDeploy = Map.fromList [(1,"Standard (Single-AZ"), (2, "Multi-AZ")]


text:
package org.lwjgl.vulkan;

import javax.annotation.*;

import java.nio.*;

import org.lwjgl.*;
import org.lwjgl.system.*;

import static org.lwjgl.system.MemoryUtil.*;
import static org.lwjgl.system.MemoryStack.*;

/**
 * Structure specifying parameters returned to the callback.
 *
 *
Description

 *
 *
If the {@code reportAddressBinding} feature is enabled and the implementation binds or unbinds a region of virtual address space associated with a Vulkan object, the implementation must submit a debug message with the following properties:

 *
 *

 *
{@code messageSeverity} equal to {@link EXTDebugUtils#VK_DEBUG_UTILS_MESSAGE_SEVERITY_INFO_BIT_EXT DEBUG_UTILS_MESSAGE_SEVERITY_INFO_BIT_EXT}

 *
{@code messageType} equal to {@link EXTDeviceAddressBindingReport#VK_DEBUG_UTILS_MESSAGE_TYPE_DEVICE_ADDRESS_BINDING_BIT_EXT DEBUG_UTILS_MESSAGE_TYPE_DEVICE_ADDRESS_BINDING_BIT_EXT}

 *
{@link VkDebugUtilsMessengerCallbackDataEXT}{@code ::pObjects} must identify the associated Vulkan object

 *
{@link VkDeviceAddressBindingCallbackDataEXT} must be included in the {@code pNext} chain of {@link VkDebugUtilsMessengerCallbackDataEXT}

 *

 *
 *
These debug messages must be emitted both for GPU virtual address space regions that are explicitly bound to a Vulkan object via the {@code vkBind}*Memory/{@code vkBind}*Memory2 functions, and for those that are implicitly generated via memory allocation or importing external memory.

 *
 *
An implementation may report binding events associated with a Vulkan object via {@code VkDebugUtilsMessengerEXT} prior to the object becoming visible to an application via other Vulkan commands. For example, object creation functions may report binding events that occur during an objects creation. In such cases, {@link VkDeviceAddressBindingCallbackDataEXT}{@code ::flags} must include {@link EXTDeviceAddressBindingReport#VK_DEVICE_ADDRESS_BINDING_INTERNAL_OBJECT_BIT_EXT DEVICE_ADDRESS_BINDING_INTERNAL_OBJECT_BIT_EXT}.

 *
 *
Object handles reported in this manner are not valid object handles, and must not be used as an input parameter to any Vulkan command.

 *
 *
Any valid object handle returned by an object creation function must match the handle specified via any previously reported binding events associated with the object's creation.

 *
 *
Valid Usage (Implicit)

 *
 *

 *
{@code sType} must be {@link EXTDeviceAddressBindingReport#VK_STRUCTURE_TYPE_DEVICE_ADDRESS_BINDING_CALLBACK_DATA_EXT STRUCTURE_TYPE_DEVICE_ADDRESS_BINDING_CALLBACK_DATA_EXT}

 *
{@code flags} must be a valid combination of {@code VkDeviceAddressBindingFlagBitsEXT} values

 *
{@code bindingType} must be a valid {@code VkDeviceAddressBindingTypeEXT} value

 *

 *
 *
Layout

 *
 *

 * struct VkDeviceAddressBindingCallbackDataEXT {
 *     VkStructureType {@link #sType};
 *     void * {@link #pNext};
 *     VkDeviceAddressBindingFlagsEXT {@link #flags};
 *     VkDeviceAddress {@link #baseAddress};
 *     VkDeviceSize {@link #size};
 *     VkDeviceAddressBindingTypeEXT {@link #bindingType};
 * }

 */
public class VkDeviceAddressBindingCallbackDataEXT extends Struct implements NativeResource {

    /** The struct size in bytes. */
    public static final int SIZEOF;

    /** The struct alignment in bytes. */
    public static final int ALIGNOF;

    /** The struct member offsets. */
    public static final int
        STYPE,
        PNEXT,
        FLAGS,
        BASEADDRESS,
        SIZE,
        BINDINGTYPE;

    static {
        Layout layout = __struct(
            __member(4),
            __member(POINTER_SIZE),
            __member(4),
            __member(8),
            __member(8),
            __member(4)
        );

        SIZEOF = layout.getSize();
        ALIGNOF = layout.getAlignment();

        STYPE = layout.offsetof(0);
        PNEXT = layout.offsetof(1);
        FLAGS = layout.offsetof(2);
        BASEADDRESS = layout.offsetof(3);
        SIZE = layout.offsetof(4);
        BINDINGTYPE = layout.offsetof(5);
    }

    /**
     * Creates a {@code VkDeviceAddressBindingCallbackDataEXT} instance at the current position of the specified {@link ByteBuffer} container. Changes to the buffer's content will be
     * visible to the struct instance and vice versa.
     *
     *
The created instance holds a strong reference to the container object.

     */
    public VkDeviceAddressBindingCallbackDataEXT(ByteBuffer container) {
        super(memAddress(container), __checkContainer(container, SIZEOF));
    }

    @Override
    public int sizeof() { return SIZEOF; }

    /** the type of this structure. */
    @NativeType("VkStructureType")
    public int sType() { return nsType(address()); }
    /** {@code NULL} or a pointer to a structure extending this structure. */
    @NativeType("void *")
    public long pNext() { return npNext(address()); }
    /** a bitmask of {@code VkDeviceAddressBindingFlagBitsEXT} specifying additional information about the binding event that caused the callback to be called. */
    @NativeType("VkDeviceAddressBindingFlagsEXT")
    public int flags() { return nflags(address()); }
    /** a GPU-accessible virtual address identifying the start of a region of the virtual address space associated with a Vulkan object, as identified by the {@code pObjects} member of {@link VkDebugUtilsMessengerCallbackDataEXT}. */
    @NativeType("VkDeviceAddress")
    public long baseAddress() { return nbaseAddress(address()); }
    /** the size in bytes of a region of GPU-accessible virtual address space. */
    @NativeType("VkDeviceSize")
    public long size() { return nsize(address()); }
    /** a {@code VkDeviceAddressBindingTypeEXT} specifying the type of binding event that caused the callback to be called. */
    @NativeType("VkDeviceAddressBindingTypeEXT")
    public int bindingType() { return nbindingType(address()); }

    /** Sets the specified value to the {@link #sType} field. */
    public VkDeviceAddressBindingCallbackDataEXT sType(@NativeType("VkStructureType") int value) { nsType(address(), value); return this; }
    /** Sets the {@link EXTDeviceAddressBindingReport#VK_STRUCTURE_TYPE_DEVICE_ADDRESS_BINDING_CALLBACK_DATA_EXT STRUCTURE_TYPE_DEVICE_ADDRESS_BINDING_CALLBACK_DATA_EXT} value to the {@link #sType} field. */
    public VkDeviceAddressBindingCallbackDataEXT sType$Default() { return sType(EXTDeviceAddressBindingReport.VK_STRUCTURE_TYPE_DEVICE_ADDRESS_BINDING_CALLBACK_DATA_EXT); }
    /** Sets the specified value to the {@link #pNext} field. */
    public VkDeviceAddressBindingCallbackDataEXT pNext(@NativeType("void *") long value) { npNext(address(), value); return this; }
    /** Sets the specified value to the {@link #flags} field. */
    public VkDeviceAddressBindingCallbackDataEXT flags(@NativeType("VkDeviceAddressBindingFlagsEXT") int value) { nflags(address(), value); return this; }
    /** Sets the specified value to the {@link #baseAddress} field. */
    public VkDeviceAddressBindingCallbackDataEXT baseAddress(@NativeType("VkDeviceAddress") long value) { nbaseAddress(address(), value); return this; }
    /** Sets the specified value to the {@link #size} field. */
    public VkDeviceAddressBindingCallbackDataEXT size(@NativeType("VkDeviceSize") long value) { nsize(address(), value); return this; }
    /** Sets the specified value to the {@link #bindingType} field. */
    public VkDeviceAddressBindingCallbackDataEXT bindingType(@NativeType("VkDeviceAddressBindingTypeEXT") int value) { nbindingType(address(), value); return this; }

    /** Initializes this struct with the specified values. */
    public VkDeviceAddressBindingCallbackDataEXT set(
        int sType,
        long pNext,
        int flags,
        long baseAddress,
        long size,
        int bindingType
    ) {
        sType(sType);
        pNext(pNext);
        flags(flags);
        baseAddress(baseAddress);
        size(size);
        bindingType(bindingType);

        return this;
    }

    /**
     * Copies the specified struct data to this struct.
     *
     * @param src the source struct
     *
     * @return this struct
     */
    public VkDeviceAddressBindingCallbackDataEXT set(VkDeviceAddressBindingCallbackDataEXT src) {
        memCopy(src.address(), address(), SIZEOF);
        return this;
    }

    // -----------------------------------

    /** Returns a new {@code VkDeviceAddressBindingCallbackDataEXT} instance allocated with {@link MemoryUtil#memAlloc memAlloc}. The instance must be explicitly freed. */
    public static VkDeviceAddressBindingCallbackDataEXT malloc() {
        return wrap(VkDeviceAddressBindingCallbackDataEXT.class, nmemAllocChecked(SIZEOF));
    }

    /** Returns a new {@code VkDeviceAddressBindingCallbackDataEXT} instance allocated with {@link MemoryUtil#memCalloc memCalloc}. The instance must be explicitly freed. */
    public static VkDeviceAddressBindingCallbackDataEXT calloc() {
        return wrap(VkDeviceAddressBindingCallbackDataEXT.class, nmemCallocChecked(1, SIZEOF));
    }

    /** Returns a new {@code VkDeviceAddressBindingCallbackDataEXT} instance allocated with {@link BufferUtils}. */
    public static VkDeviceAddressBindingCallbackDataEXT create() {
        ByteBuffer container = BufferUtils.createByteBuffer(SIZEOF);
        return wrap(VkDeviceAddressBindingCallbackDataEXT.class, memAddress(container), container);
    }

    /** Returns a new {@code VkDeviceAddressBindingCallbackDataEXT} instance for the specified memory address. */
    public static VkDeviceAddressBindingCallbackDataEXT create(long address) {
        return wrap(VkDeviceAddressBindingCallbackDataEXT.class, address);
    }

    /** Like {@link #create(long) create}, but returns {@code null} if {@code address} is {@code NULL}. */
    @Nullable
    public static VkDeviceAddressBindingCallbackDataEXT createSafe(long address) {
        return address == NULL ? null : wrap(VkDeviceAddressBindingCallbackDataEXT.class, address);
    }

    /**
     * Returns a new {@link VkDeviceAddressBindingCallbackDataEXT.Buffer} instance allocated with {@link MemoryUtil#memAlloc memAlloc}. The instance must be explicitly freed.
     *
     * @param capacity the buffer capacity
     */
    public static VkDeviceAddressBindingCallbackDataEXT.Buffer malloc(int capacity) {
        return wrap(Buffer.class, nmemAllocChecked(__checkMalloc(capacity, SIZEOF)), capacity);
    }

    /**
     * Returns a new {@link VkDeviceAddressBindingCallbackDataEXT.Buffer} instance allocated with {@link MemoryUtil#memCalloc memCalloc}. The instance must be explicitly freed.
     *
     * @param capacity the buffer capacity
     */
    public static VkDeviceAddressBindingCallbackDataEXT.Buffer calloc(int capacity) {
        return wrap(Buffer.class, nmemCallocChecked(capacity, SIZEOF), capacity);
    }

    /**
     * Returns a new {@link VkDeviceAddressBindingCallbackDataEXT.Buffer} instance allocated with {@link BufferUtils}.
     *
     * @param capacity the buffer capacity
     */
    public static VkDeviceAddressBindingCallbackDataEXT.Buffer create(int capacity) {
        ByteBuffer container = __create(capacity, SIZEOF);
        return wrap(Buffer.class, memAddress(container), capacity, container);
    }

    /**
     * Create a {@link VkDeviceAddressBindingCallbackDataEXT.Buffer} instance at the specified memory.
     *
     * @param address  the memory address
     * @param capacity the buffer capacity
     */
    public static VkDeviceAddressBindingCallbackDataEXT.Buffer create(long address, int capacity) {
        return wrap(Buffer.class, address, capacity);
    }

    /** Like {@link #create(long, int) create}, but returns {@code null} if {@code address} is {@code NULL}. */
    @Nullable
    public static VkDeviceAddressBindingCallbackDataEXT.Buffer createSafe(long address, int capacity) {
        return address == NULL ? null : wrap(Buffer.class, address, capacity);
    }

    /**
     * Returns a new {@code VkDeviceAddressBindingCallbackDataEXT} instance allocated on the specified {@link MemoryStack}.
     *
     * @param stack the stack from which to allocate
     */
    public static VkDeviceAddressBindingCallbackDataEXT malloc(MemoryStack stack) {
        return wrap(VkDeviceAddressBindingCallbackDataEXT.class, stack.nmalloc(ALIGNOF, SIZEOF));
    }

    /**
     * Returns a new {@code VkDeviceAddressBindingCallbackDataEXT} instance allocated on the specified {@link MemoryStack} and initializes all its bits to zero.
     *
     * @param stack the stack from which to allocate
     */
    public static VkDeviceAddressBindingCallbackDataEXT calloc(MemoryStack stack) {
        return wrap(VkDeviceAddressBindingCallbackDataEXT.class, stack.ncalloc(ALIGNOF, 1, SIZEOF));
    }

    /**
     * Returns a new {@link VkDeviceAddressBindingCallbackDataEXT.Buffer} instance allocated on the specified {@link MemoryStack}.
     *
     * @param stack    the stack from which to allocate
     * @param capacity the buffer capacity
     */
    public static VkDeviceAddressBindingCallbackDataEXT.Buffer malloc(int capacity, MemoryStack stack) {
        return wrap(Buffer.class, stack.nmalloc(ALIGNOF, capacity * SIZEOF), capacity);
    }

    /**
     * Returns a new {@link VkDeviceAddressBindingCallbackDataEXT.Buffer} instance allocated on the specified {@link MemoryStack} and initializes all its bits to zero.
     *
     * @param stack    the stack from which to allocate
     * @param capacity the buffer capacity
     */
    public static VkDeviceAddressBindingCallbackDataEXT.Buffer calloc(int capacity, MemoryStack stack) {
        return wrap(Buffer.class, stack.ncalloc(ALIGNOF, capacity, SIZEOF), capacity);
    }

    // -----------------------------------

    /** Unsafe version of {@link #sType}. */
    public static int nsType(long struct) { return UNSAFE.getInt(null, struct + VkDeviceAddressBindingCallbackDataEXT.STYPE); }
    /** Unsafe version of {@link #pNext}. */
    public static long npNext(long struct) { return memGetAddress(struct + VkDeviceAddressBindingCallbackDataEXT.PNEXT); }
    /** Unsafe version of {@link #flags}. */
    public static int nflags(long struct) { return UNSAFE.getInt(null, struct + VkDeviceAddressBindingCallbackDataEXT.FLAGS); }
    /** Unsafe version of {@link #baseAddress}. */
    public static long nbaseAddress(long struct) { return UNSAFE.getLong(null, struct + VkDeviceAddressBindingCallbackDataEXT.BASEADDRESS); }
    /** Unsafe version of {@link #size}. */
    public static long nsize(long struct) { return UNSAFE.getLong(null, struct + VkDeviceAddressBindingCallbackDataEXT.SIZE); }
    /** Unsafe version of {@link #bindingType}. */
    public static int nbindingType(long struct) { return UNSAFE.getInt(null, struct + VkDeviceAddressBindingCallbackDataEXT.BINDINGTYPE); }

    /** Unsafe version of {@link #sType(int) sType}. */
    public static void nsType(long struct, int value) { UNSAFE.putInt(null, struct + VkDeviceAddressBindingCallbackDataEXT.STYPE, value); }
    /** Unsafe version of {@link #pNext(long) pNext}. */
    public static void npNext(long struct, long value) { memPutAddress(struct + VkDeviceAddressBindingCallbackDataEXT.PNEXT, value); }
    /** Unsafe version of {@link #flags(int) flags}. */
    public static void nflags(long struct, int value) { UNSAFE.putInt(null, struct + VkDeviceAddressBindingCallbackDataEXT.FLAGS, value); }
    /** Unsafe version of {@link #baseAddress(long) baseAddress}. */
    public static void nbaseAddress(long struct, long value) { UNSAFE.putLong(null, struct + VkDeviceAddressBindingCallbackDataEXT.BASEADDRESS, value); }
    /** Unsafe version of {@link #size(long) size}. */
    public static void nsize(long struct, long value) { UNSAFE.putLong(null, struct + VkDeviceAddressBindingCallbackDataEXT.SIZE, value); }
    /** Unsafe version of {@link #bindingType(int) bindingType}. */
    public static void nbindingType(long struct, int value) { UNSAFE.putInt(null, struct + VkDeviceAddressBindingCallbackDataEXT.BINDINGTYPE, value); }

    // -----------------------------------

    /** An array of {@link VkDeviceAddressBindingCallbackDataEXT} structs. */
    public static class Buffer extends StructBuffer<VkDeviceAddressBindingCallbackDataEXT, Buffer> implements NativeResource {

        private static final VkDeviceAddressBindingCallbackDataEXT ELEMENT_FACTORY = VkDeviceAddressBindingCallbackDataEXT.create(-1L);

        /**
         * Creates a new {@code VkDeviceAddressBindingCallbackDataEXT.Buffer} instance backed by the specified container.
         *
         * Changes to the container's content will be visible to the struct buffer instance and vice versa. The two buffers' position, limit, and mark values
         * will be independent. The new buffer's position will be zero, its capacity and its limit will be the number of bytes remaining in this buffer divided
         * by {@link VkDeviceAddressBindingCallbackDataEXT#SIZEOF}, and its mark will be undefined.
         *
         *
The created buffer instance holds a strong reference to the container object.

         */
        public Buffer(ByteBuffer container) {
            super(container, container.remaining() / SIZEOF);
        }

        public Buffer(long address, int cap) {
            super(address, null, -1, 0, cap, cap);
        }

        Buffer(long address, @Nullable ByteBuffer container, int mark, int pos, int lim, int cap) {
            super(address, container, mark, pos, lim, cap);
        }

        @Override
        protected Buffer self() {
            return this;
        }

        @Override
        protected VkDeviceAddressBindingCallbackDataEXT getElementFactory() {
            return ELEMENT_FACTORY;
        }

        /** @return the value of the {@link VkDeviceAddressBindingCallbackDataEXT#sType} field. */
        @NativeType("VkStructureType")
        public int sType() { return VkDeviceAddressBindingCallbackDataEXT.nsType(address()); }
        /** @return the value of the {@link VkDeviceAddressBindingCallbackDataEXT#pNext} field. */
        @NativeType("void *")
        public long pNext() { return VkDeviceAddressBindingCallbackDataEXT.npNext(address()); }
        /** @return the value of the {@link VkDeviceAddressBindingCallbackDataEXT#flags} field. */
        @NativeType("VkDeviceAddressBindingFlagsEXT")
        public int flags() { return VkDeviceAddressBindingCallbackDataEXT.nflags(address()); }
        /** @return the value of the {@link VkDeviceAddressBindingCallbackDataEXT#baseAddress} field. */
        @NativeType("VkDeviceAddress")
        public long baseAddress() { return VkDeviceAddressBindingCallbackDataEXT.nbaseAddress(address()); }
        /** @return the value of the {@link VkDeviceAddressBindingCallbackDataEXT#size} field. */
        @NativeType("VkDeviceSize")
        public long size() { return VkDeviceAddressBindingCallbackDataEXT.nsize(address()); }
        /** @return the value of the {@link VkDeviceAddressBindingCallbackDataEXT#bindingType} field. */
        @NativeType("VkDeviceAddressBindingTypeEXT")
        public int bindingType() { return VkDeviceAddressBindingCallbackDataEXT.nbindingType(address()); }

        /** Sets the specified value to the {@link VkDeviceAddressBindingCallbackDataEXT#sType} field. */
        public VkDeviceAddressBindingCallbackDataEXT.Buffer sType(@NativeType("VkStructureType") int value) { VkDeviceAddressBindingCallbackDataEXT.nsType(address(), value); return this; }
        /** Sets the {@link EXTDeviceAddressBindingReport#VK_STRUCTURE_TYPE_DEVICE_ADDRESS_BINDING_CALLBACK_DATA_EXT STRUCTURE_TYPE_DEVICE_ADDRESS_BINDING_CALLBACK_DATA_EXT} value to the {@link VkDeviceAddressBindingCallbackDataEXT#sType} field. */
        public VkDeviceAddressBindingCallbackDataEXT.Buffer sType$Default() { return sType(EXTDeviceAddressBindingReport.VK_STRUCTURE_TYPE_DEVICE_ADDRESS_BINDING_CALLBACK_DATA_EXT); }
        /** Sets the specified value to the {@link VkDeviceAddressBindingCallbackDataEXT#pNext} field. */
        public VkDeviceAddressBindingCallbackDataEXT.Buffer pNext(@NativeType("void *") long value) { VkDeviceAddressBindingCallbackDataEXT.npNext(address(), value); return this; }
        /** Sets the specified value to the {@link VkDeviceAddressBindingCallbackDataEXT#flags} field. */
        public VkDeviceAddressBindingCallbackDataEXT.Buffer flags(@NativeType("VkDeviceAddressBindingFlagsEXT") int value) { VkDeviceAddressBindingCallbackDataEXT.nflags(address(), value); return this; }
        /** Sets the specified value to the {@link VkDeviceAddressBindingCallbackDataEXT#baseAddress} field. */
        public VkDeviceAddressBindingCallbackDataEXT.Buffer baseAddress(@NativeType("VkDeviceAddress") long value) { VkDeviceAddressBindingCallbackDataEXT.nbaseAddress(address(), value); return this; }
        /** Sets the specified value to the {@link VkDeviceAddressBindingCallbackDataEXT#size} field. */
        public VkDeviceAddressBindingCallbackDataEXT.Buffer size(@NativeType("VkDeviceSize") long value) { VkDeviceAddressBindingCallbackDataEXT.nsize(address(), value); return this; }
        /** Sets the specified value to the {@link VkDeviceAddressBindingCallbackDataEXT#bindingType} field. */
        public VkDeviceAddressBindingCallbackDataEXT.Buffer bindingType(@NativeType("VkDeviceAddressBindingTypeEXT") int value) { VkDeviceAddressBindingCallbackDataEXT.nbindingType(address(), value); return this; }

    }

}


text:
ACCEPTED

#### According to
Index Fungorum

#### Published in
Select. fung. carpol. (Paris) 2: 271 (1863)

#### Original name
Sphaeria clavariarum Tul. & C. Tul.

### Remarks
null