params) {
+ super(params);
+ }
+
+ public PIPESParams(String... params) {
+ super(params);
+ }
+
+ @Override
+ public String toString() {
+ return StringUtil.join(params.toArray(new String[0]), "|");
+ }
+ }
+
+}
diff --git a/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/StringUtil.java b/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/StringUtil.java
new file mode 100644
index 00000000000..ab160d65a19
--- /dev/null
+++ b/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/StringUtil.java
@@ -0,0 +1,42 @@
+package io.swagger.client;
+
+@javax.annotation.Generated(value = "class io.swagger.codegen.languages.JavaClientCodegen", date = "2016-01-21T16:52:39.577+01:00")
+public class StringUtil {
+ /**
+ * Check if the given array contains the given value (with case-insensitive comparison).
+ *
+ * @param array The array
+ * @param value The value to search
+ * @return true if the array contains the value
+ */
+ public static boolean containsIgnoreCase(String[] array, String value) {
+ for (String str : array) {
+ if (value == null && str == null) return true;
+ if (value != null && value.equalsIgnoreCase(str)) return true;
+ }
+ return false;
+ }
+
+ /**
+ * Join an array of strings with the given separator.
+ *
+ * Note: This might be replaced by utility method from commons-lang or guava someday
+ * if one of those libraries is added as dependency.
+ *
+ *
+ * @param array The array of strings
+ * @param separator The separator
+ * @return the resulting string
+ */
+ public static String join(String[] array, String separator) {
+ int len = array.length;
+ if (len == 0) return "";
+
+ StringBuilder out = new StringBuilder();
+ out.append(array[0]);
+ for (int i = 1; i < len; i++) {
+ out.append(separator).append(array[i]);
+ }
+ return out.toString();
+ }
+}
diff --git a/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/api/PetApi.java b/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/api/PetApi.java
new file mode 100644
index 00000000000..7caa426e18d
--- /dev/null
+++ b/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/api/PetApi.java
@@ -0,0 +1,155 @@
+package io.swagger.client.api;
+
+import io.swagger.client.CollectionFormats.*;
+
+import rx.Observable;
+
+import retrofit.http.*;
+
+import com.squareup.okhttp.RequestBody;
+
+import io.swagger.client.model.Pet;
+import java.io.File;
+
+import java.util.*;
+
+public interface PetApi {
+
+ /**
+ * Update an existing pet
+ *
+ * @param body Pet object that needs to be added to the store
+ * @return Call
+ */
+
+ @PUT("pet")
+ Observable updatePet(
+ @Body Pet body
+ );
+
+
+ /**
+ * Add a new pet to the store
+ *
+ * @param body Pet object that needs to be added to the store
+ * @return Call
+ */
+
+ @POST("pet")
+ Observable addPet(
+ @Body Pet body
+ );
+
+
+ /**
+ * Finds Pets by status
+ * Multiple status values can be provided with comma seperated strings
+ * @param status Status values that need to be considered for filter
+ * @return Call>
+ */
+
+ @GET("pet/findByStatus")
+ Observable> findPetsByStatus(
+ @Query("status") List status
+ );
+
+
+ /**
+ * Finds Pets by tags
+ * Muliple tags can be provided with comma seperated strings. Use tag1, tag2, tag3 for testing.
+ * @param tags Tags to filter by
+ * @return Call>
+ */
+
+ @GET("pet/findByTags")
+ Observable> findPetsByTags(
+ @Query("tags") List tags
+ );
+
+
+ /**
+ * Find pet by ID
+ * Returns a pet when ID < 10. ID > 10 or nonintegers will simulate API error conditions
+ * @param petId ID of pet that needs to be fetched
+ * @return Call
+ */
+
+ @GET("pet/{petId}")
+ Observable getPetById(
+ @Path("petId") Long petId
+ );
+
+
+ /**
+ * Updates a pet in the store with form data
+ *
+ * @param petId ID of pet that needs to be updated
+ * @param name Updated name of the pet
+ * @param status Updated status of the pet
+ * @return Call
+ */
+
+ @FormUrlEncoded
+ @POST("pet/{petId}")
+ Observable updatePetWithForm(
+ @Path("petId") String petId, @Field("name") String name, @Field("status") String status
+ );
+
+
+ /**
+ * Deletes a pet
+ *
+ * @param petId Pet id to delete
+ * @param apiKey
+ * @return Call
+ */
+
+ @DELETE("pet/{petId}")
+ Observable deletePet(
+ @Path("petId") Long petId, @Header("api_key") String apiKey
+ );
+
+
+ /**
+ * uploads an image
+ *
+ * @param petId ID of pet to update
+ * @param additionalMetadata Additional data to pass to server
+ * @param file file to upload
+ * @return Call
+ */
+
+ @Multipart
+ @POST("pet/{petId}/uploadImage")
+ Observable uploadFile(
+ @Path("petId") Long petId, @Part("additionalMetadata") String additionalMetadata, @Part("file\"; filename=\"file\"") RequestBody file
+ );
+
+
+ /**
+ * Fake endpoint to test byte array return by 'Find pet by ID'
+ * Returns a pet when ID < 10. ID > 10 or nonintegers will simulate API error conditions
+ * @param petId ID of pet that needs to be fetched
+ * @return Call
+ */
+
+ @GET("pet/{petId}?testing_byte_array=true")
+ Observable getPetByIdWithByteArray(
+ @Path("petId") Long petId
+ );
+
+
+ /**
+ * Fake endpoint to test byte array in body parameter for adding a new pet to the store
+ *
+ * @param body Pet object in the form of byte array
+ * @return Call
+ */
+
+ @POST("pet?testing_byte_array=true")
+ Observable addPetUsingByteArray(
+ @Body byte[] body
+ );
+
+
+}
diff --git a/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/api/StoreApi.java b/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/api/StoreApi.java
new file mode 100644
index 00000000000..20e4dbb57fa
--- /dev/null
+++ b/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/api/StoreApi.java
@@ -0,0 +1,68 @@
+package io.swagger.client.api;
+
+import io.swagger.client.CollectionFormats.*;
+
+import rx.Observable;
+
+import retrofit.http.*;
+
+import com.squareup.okhttp.RequestBody;
+
+import java.util.Map;
+import io.swagger.client.model.Order;
+
+import java.util.*;
+
+public interface StoreApi {
+
+ /**
+ * Returns pet inventories by status
+ * Returns a map of status codes to quantities
+ * @return Call>
+ */
+
+ @GET("store/inventory")
+ Observable> getInventory();
+
+
+
+ /**
+ * Place an order for a pet
+ *
+ * @param body order placed for purchasing the pet
+ * @return Call
+ */
+
+ @POST("store/order")
+ Observable placeOrder(
+ @Body Order body
+ );
+
+
+ /**
+ * Find purchase order by ID
+ * For valid response try integer IDs with value <= 5 or > 10. Other values will generated exceptions
+ * @param orderId ID of pet that needs to be fetched
+ * @return Call
+ */
+
+ @GET("store/order/{orderId}")
+ Observable getOrderById(
+ @Path("orderId") String orderId
+ );
+
+
+ /**
+ * Delete purchase order by ID
+ * For valid response try integer IDs with value < 1000. Anything above 1000 or nonintegers will generate API errors
+ * @param orderId ID of the order that needs to be deleted
+ * @return Call
+ */
+
+ @DELETE("store/order/{orderId}")
+ Observable deleteOrder(
+ @Path("orderId") String orderId
+ );
+
+
+}
diff --git a/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/api/UserApi.java b/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/api/UserApi.java
new file mode 100644
index 00000000000..ec6fd019252
--- /dev/null
+++ b/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/api/UserApi.java
@@ -0,0 +1,122 @@
+package io.swagger.client.api;
+
+import io.swagger.client.CollectionFormats.*;
+
+import rx.Observable;
+
+import retrofit.http.*;
+
+import com.squareup.okhttp.RequestBody;
+
+import io.swagger.client.model.User;
+import java.util.*;
+
+import java.util.*;
+
+public interface UserApi {
+
+ /**
+ * Create user
+ * This can only be done by the logged in user.
+ * @param body Created user object
+ * @return Call
+ */
+
+ @POST("user")
+ Observable createUser(
+ @Body User body
+ );
+
+
+ /**
+ * Creates list of users with given input array
+ *
+ * @param body List of user object
+ * @return Call
+ */
+
+ @POST("user/createWithArray")
+ Observable createUsersWithArrayInput(
+ @Body List body
+ );
+
+
+ /**
+ * Creates list of users with given input array
+ *
+ * @param body List of user object
+ * @return Call
+ */
+
+ @POST("user/createWithList")
+ Observable createUsersWithListInput(
+ @Body List body
+ );
+
+
+ /**
+ * Logs user into the system
+ *
+ * @param username The user name for login
+ * @param password The password for login in clear text
+ * @return Call
+ */
+
+ @GET("user/login")
+ Observable loginUser(
+ @Query("username") String username, @Query("password") String password
+ );
+
+
+ /**
+ * Logs out current logged in user session
+ *
+ * @return Call
+ */
+
+ @GET("user/logout")
+ Observable logoutUser();
+
+
+
+ /**
+ * Get user by user name
+ *
+ * @param username The name that needs to be fetched. Use user1 for testing.
+ * @return Call
+ */
+
+ @GET("user/{username}")
+ Observable getUserByName(
+ @Path("username") String username
+ );
+
+
+ /**
+ * Updated user
+ * This can only be done by the logged in user.
+ * @param username name that need to be deleted
+ * @param body Updated user object
+ * @return Call
+ */
+
+ @PUT("user/{username}")
+ Observable updateUser(
+ @Path("username") String username, @Body User body
+ );
+
+
+ /**
+ * Delete user
+ * This can only be done by the logged in user.
+ * @param username The name that needs to be deleted
+ * @return Call
+ */
+
+ @DELETE("user/{username}")
+ Observable deleteUser(
+ @Path("username") String username
+ );
+
+
+}
diff --git a/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/auth/ApiKeyAuth.java b/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/auth/ApiKeyAuth.java
new file mode 100644
index 00000000000..59d01238796
--- /dev/null
+++ b/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/auth/ApiKeyAuth.java
@@ -0,0 +1,68 @@
+package io.swagger.client.auth;
+
+import java.io.IOException;
+import java.net.URI;
+import java.net.URISyntaxException;
+
+import com.squareup.okhttp.Interceptor;
+import com.squareup.okhttp.Request;
+import com.squareup.okhttp.Response;
+
+public class ApiKeyAuth implements Interceptor {
+ private final String location;
+ private final String paramName;
+
+ private String apiKey;
+
+ public ApiKeyAuth(String location, String paramName) {
+ this.location = location;
+ this.paramName = paramName;
+ }
+
+ public String getLocation() {
+ return location;
+ }
+
+ public String getParamName() {
+ return paramName;
+ }
+
+ public String getApiKey() {
+ return apiKey;
+ }
+
+ public void setApiKey(String apiKey) {
+ this.apiKey = apiKey;
+ }
+
+ @Override
+ public Response intercept(Chain chain) throws IOException {
+ String paramValue;
+ Request request = chain.request();
+
+ if (location == "query") {
+ String newQuery = request.uri().getQuery();
+ paramValue = paramName + "=" + apiKey;
+ if (newQuery == null) {
+ newQuery = paramValue;
+ } else {
+ newQuery += "&" + paramValue;
+ }
+
+ URI newUri;
+ try {
+ newUri = new URI(request.uri().getScheme(), request.uri().getAuthority(),
+ request.uri().getPath(), newQuery, request.uri().getFragment());
+ } catch (URISyntaxException e) {
+ throw new IOException(e);
+ }
+
+ request = request.newBuilder().url(newUri.toURL()).build();
+ } else if (location == "header") {
+ request = request.newBuilder()
+ .addHeader(paramName, apiKey)
+ .build();
+ }
+ return chain.proceed(request);
+ }
+}
\ No newline at end of file
diff --git a/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/auth/HttpBasicAuth.java b/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/auth/HttpBasicAuth.java
new file mode 100644
index 00000000000..cb7c617767b
--- /dev/null
+++ b/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/auth/HttpBasicAuth.java
@@ -0,0 +1,49 @@
+package io.swagger.client.auth;
+
+import java.io.IOException;
+
+import com.squareup.okhttp.Credentials;
+import com.squareup.okhttp.Interceptor;
+import com.squareup.okhttp.Request;
+import com.squareup.okhttp.Response;
+
+public class HttpBasicAuth implements Interceptor {
+
+ private String username;
+ private String password;
+
+ public String getUsername() {
+ return username;
+ }
+
+ public void setUsername(String username) {
+ this.username = username;
+ }
+
+ public String getPassword() {
+ return password;
+ }
+
+ public void setPassword(String password) {
+ this.password = password;
+ }
+
+ public void setCredentials(String username, String password) {
+ this.username = username;
+ this.password = password;
+ }
+
+ @Override
+ public Response intercept(Chain chain) throws IOException {
+ Request request = chain.request();
+
+ // If the request already have an authorization (eg. Basic auth), do nothing
+ if (request.header("Authorization") == null) {
+ String credentials = Credentials.basic(username, password);
+ request = request.newBuilder()
+ .addHeader("Authorization", credentials)
+ .build();
+ }
+ return chain.proceed(request);
+ }
+}
diff --git a/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/auth/OAuth.java b/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/auth/OAuth.java
new file mode 100644
index 00000000000..80614f0f56a
--- /dev/null
+++ b/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/auth/OAuth.java
@@ -0,0 +1,161 @@
+package io.swagger.client.auth;
+
+import static java.net.HttpURLConnection.HTTP_UNAUTHORIZED;
+
+import java.io.IOException;
+import java.util.Map;
+
+import org.apache.oltu.oauth2.client.OAuthClient;
+import org.apache.oltu.oauth2.client.request.OAuthBearerClientRequest;
+import org.apache.oltu.oauth2.client.request.OAuthClientRequest;
+import org.apache.oltu.oauth2.client.request.OAuthClientRequest.AuthenticationRequestBuilder;
+import org.apache.oltu.oauth2.client.request.OAuthClientRequest.TokenRequestBuilder;
+import org.apache.oltu.oauth2.client.response.OAuthJSONAccessTokenResponse;
+import org.apache.oltu.oauth2.common.exception.OAuthProblemException;
+import org.apache.oltu.oauth2.common.exception.OAuthSystemException;
+import org.apache.oltu.oauth2.common.message.types.GrantType;
+import org.apache.oltu.oauth2.common.token.BasicOAuthToken;
+
+import com.squareup.okhttp.Interceptor;
+import com.squareup.okhttp.OkHttpClient;
+import com.squareup.okhttp.Request;
+import com.squareup.okhttp.Request.Builder;
+import com.squareup.okhttp.Response;
+
+public class OAuth implements Interceptor {
+
+ public interface AccessTokenListener {
+ public void notify(BasicOAuthToken token);
+ }
+
+ private volatile String accessToken;
+ private OAuthClient oauthClient;
+
+ private TokenRequestBuilder tokenRequestBuilder;
+ private AuthenticationRequestBuilder authenticationRequestBuilder;
+
+ private AccessTokenListener accessTokenListener;
+
+ public OAuth( OkHttpClient client, TokenRequestBuilder requestBuilder ) {
+ this.oauthClient = new OAuthClient(new OAuthOkHttpClient(client));
+ this.tokenRequestBuilder = requestBuilder;
+ }
+
+ public OAuth(TokenRequestBuilder requestBuilder ) {
+ this(new OkHttpClient(), requestBuilder);
+ }
+
+ public OAuth(OAuthFlow flow, String authorizationUrl, String tokenUrl, String scopes) {
+ this(OAuthClientRequest.tokenLocation(tokenUrl).setScope(scopes));
+ setFlow(flow);
+ authenticationRequestBuilder = OAuthClientRequest.authorizationLocation(authorizationUrl);
+ }
+
+ public void setFlow(OAuthFlow flow) {
+ switch(flow) {
+ case accessCode:
+ case implicit:
+ tokenRequestBuilder.setGrantType(GrantType.AUTHORIZATION_CODE);
+ break;
+ case password:
+ tokenRequestBuilder.setGrantType(GrantType.PASSWORD);
+ break;
+ case application:
+ tokenRequestBuilder.setGrantType(GrantType.CLIENT_CREDENTIALS);
+ break;
+ default:
+ break;
+ }
+ }
+
+ @Override
+ public Response intercept(Chain chain)
+ throws IOException {
+
+ Request request = chain.request();
+
+ // If the request already have an authorization (eg. Basic auth), do nothing
+ if (request.header("Authorization") != null) {
+ return chain.proceed(request);
+ }
+
+ // If first time, get the token
+ OAuthClientRequest oAuthRequest;
+ if (getAccessToken() == null) {
+ updateAccessToken(null);
+ }
+
+ // Build the request
+ Builder rb = request.newBuilder();
+
+ String requestAccessToken = new String(getAccessToken());
+ try {
+ oAuthRequest = new OAuthBearerClientRequest(request.urlString())
+ .setAccessToken(requestAccessToken)
+ .buildHeaderMessage();
+ } catch (OAuthSystemException e) {
+ throw new IOException(e);
+ }
+
+ for ( Map.Entry header : oAuthRequest.getHeaders().entrySet() ) {
+ rb.addHeader(header.getKey(), header.getValue());
+ }
+ rb.url( oAuthRequest.getLocationUri());
+
+ //Execute the request
+ Response response = chain.proceed(rb.build());
+
+ // 401 most likely indicates that access token has expired.
+ // Time to refresh and resend the request
+ if ( response.code() == HTTP_UNAUTHORIZED ) {
+ updateAccessToken(requestAccessToken);
+ return intercept( chain );
+ }
+ return response;
+ }
+
+ public synchronized void updateAccessToken(String requestAccessToken) throws IOException {
+ if (getAccessToken() == null || getAccessToken().equals(requestAccessToken)) {
+ try {
+ OAuthJSONAccessTokenResponse accessTokenResponse = oauthClient.accessToken(this.tokenRequestBuilder.buildBodyMessage());
+ setAccessToken(accessTokenResponse.getAccessToken());
+ if (accessTokenListener != null) {
+ accessTokenListener.notify((BasicOAuthToken) accessTokenResponse.getOAuthToken());
+ }
+ } catch (OAuthSystemException e) {
+ throw new IOException(e);
+ } catch (OAuthProblemException e) {
+ throw new IOException(e);
+ }
+ }
+ }
+
+ public void registerAccessTokenListener(AccessTokenListener accessTokenListener) {
+ this.accessTokenListener = accessTokenListener;
+ }
+
+ public synchronized String getAccessToken() {
+ return accessToken;
+ }
+
+ public synchronized void setAccessToken(String accessToken) {
+ this.accessToken = accessToken;
+ }
+
+ public TokenRequestBuilder getTokenRequestBuilder() {
+ return tokenRequestBuilder;
+ }
+
+ public void setTokenRequestBuilder(TokenRequestBuilder tokenRequestBuilder) {
+ this.tokenRequestBuilder = tokenRequestBuilder;
+ }
+
+ public AuthenticationRequestBuilder getAuthenticationRequestBuilder() {
+ return authenticationRequestBuilder;
+ }
+
+ public void setAuthenticationRequestBuilder(AuthenticationRequestBuilder authenticationRequestBuilder) {
+ this.authenticationRequestBuilder = authenticationRequestBuilder;
+ }
+
+}
diff --git a/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/auth/OAuthFlow.java b/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/auth/OAuthFlow.java
new file mode 100644
index 00000000000..597ec99b48b
--- /dev/null
+++ b/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/auth/OAuthFlow.java
@@ -0,0 +1,5 @@
+package io.swagger.client.auth;
+
+public enum OAuthFlow {
+ accessCode, implicit, password, application
+}
\ No newline at end of file
diff --git a/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/auth/OAuthOkHttpClient.java b/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/auth/OAuthOkHttpClient.java
new file mode 100644
index 00000000000..c872901ba24
--- /dev/null
+++ b/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/auth/OAuthOkHttpClient.java
@@ -0,0 +1,69 @@
+package io.swagger.client.auth;
+
+import java.io.IOException;
+import java.util.Map;
+import java.util.Map.Entry;
+
+import org.apache.oltu.oauth2.client.HttpClient;
+import org.apache.oltu.oauth2.client.request.OAuthClientRequest;
+import org.apache.oltu.oauth2.client.response.OAuthClientResponse;
+import org.apache.oltu.oauth2.client.response.OAuthClientResponseFactory;
+import org.apache.oltu.oauth2.common.exception.OAuthProblemException;
+import org.apache.oltu.oauth2.common.exception.OAuthSystemException;
+
+import com.squareup.okhttp.MediaType;
+import com.squareup.okhttp.OkHttpClient;
+import com.squareup.okhttp.Request;
+import com.squareup.okhttp.RequestBody;
+import com.squareup.okhttp.Response;
+
+
+public class OAuthOkHttpClient implements HttpClient {
+
+ private OkHttpClient client;
+
+ public OAuthOkHttpClient() {
+ this.client = new OkHttpClient();
+ }
+
+ public OAuthOkHttpClient(OkHttpClient client) {
+ this.client = client;
+ }
+
+ public T execute(OAuthClientRequest request, Map headers,
+ String requestMethod, Class responseClass)
+ throws OAuthSystemException, OAuthProblemException {
+
+ MediaType mediaType = MediaType.parse("application/json");
+ Request.Builder requestBuilder = new Request.Builder().url(request.getLocationUri());
+
+ if(headers != null) {
+ for (Entry entry : headers.entrySet()) {
+ if (entry.getKey().equalsIgnoreCase("Content-Type")) {
+ mediaType = MediaType.parse(entry.getValue());
+ } else {
+ requestBuilder.addHeader(entry.getKey(), entry.getValue());
+ }
+ }
+ }
+
+ RequestBody body = request.getBody() != null ? RequestBody.create(mediaType, request.getBody()) : null;
+ requestBuilder.method(requestMethod, body);
+
+ try {
+ Response response = client.newCall(requestBuilder.build()).execute();
+ return OAuthClientResponseFactory.createCustomResponse(
+ response.body().string(),
+ response.body().contentType().toString(),
+ response.code(),
+ responseClass);
+ } catch (IOException e) {
+ throw new OAuthSystemException(e);
+ }
+ }
+
+ public void shutdown() {
+ // Nothing to do here
+ }
+
+}
diff --git a/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/model/Category.java b/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/model/Category.java
new file mode 100644
index 00000000000..d0908afd9e1
--- /dev/null
+++ b/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/model/Category.java
@@ -0,0 +1,85 @@
+package io.swagger.client.model;
+
+import java.util.Objects;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+
+import com.google.gson.annotations.SerializedName;
+
+
+
+
+@ApiModel(description = "")
+public class Category {
+
+ @SerializedName("id")
+ private Long id = null;
+
+ @SerializedName("name")
+ private String name = null;
+
+
+
+ /**
+ **/
+ @ApiModelProperty(value = "")
+ public Long getId() {
+ return id;
+ }
+ public void setId(Long id) {
+ this.id = id;
+ }
+
+
+ /**
+ **/
+ @ApiModelProperty(value = "")
+ public String getName() {
+ return name;
+ }
+ public void setName(String name) {
+ this.name = name;
+ }
+
+
+
+ @Override
+ public boolean equals(Object o) {
+ if (this == o) {
+ return true;
+ }
+ if (o == null || getClass() != o.getClass()) {
+ return false;
+ }
+ Category category = (Category) o;
+ return Objects.equals(id, category.id) &&
+ Objects.equals(name, category.name);
+ }
+
+ @Override
+ public int hashCode() {
+ return Objects.hash(id, name);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder();
+ sb.append("class Category {\n");
+
+ sb.append(" id: ").append(toIndentedString(id)).append("\n");
+ sb.append(" name: ").append(toIndentedString(name)).append("\n");
+ sb.append("}");
+ return sb.toString();
+ }
+
+ /**
+ * Convert the given object to string with each line indented by 4 spaces
+ * (except the first line).
+ */
+ private String toIndentedString(Object o) {
+ if (o == null) {
+ return "null";
+ }
+ return o.toString().replace("\n", "\n ");
+ }
+}
diff --git a/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/model/Order.java b/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/model/Order.java
new file mode 100644
index 00000000000..59c5238b626
--- /dev/null
+++ b/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/model/Order.java
@@ -0,0 +1,174 @@
+package io.swagger.client.model;
+
+import java.util.Objects;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import java.util.Date;
+
+import com.google.gson.annotations.SerializedName;
+
+
+
+
+@ApiModel(description = "")
+public class Order {
+
+ @SerializedName("id")
+ private Long id = null;
+
+ @SerializedName("petId")
+ private Long petId = null;
+
+ @SerializedName("quantity")
+ private Integer quantity = null;
+
+ @SerializedName("shipDate")
+ private Date shipDate = null;
+
+
+public enum StatusEnum {
+ @SerializedName("placed")
+ PLACED("placed"),
+
+ @SerializedName("approved")
+ APPROVED("approved"),
+
+ @SerializedName("delivered")
+ DELIVERED("delivered");
+
+ private String value;
+
+ StatusEnum(String value) {
+ this.value = value;
+ }
+
+ @Override
+ public String toString() {
+ return value;
+ }
+}
+
+ @SerializedName("status")
+ private StatusEnum status = null;
+
+ @SerializedName("complete")
+ private Boolean complete = null;
+
+
+
+ /**
+ **/
+ @ApiModelProperty(value = "")
+ public Long getId() {
+ return id;
+ }
+ public void setId(Long id) {
+ this.id = id;
+ }
+
+
+ /**
+ **/
+ @ApiModelProperty(value = "")
+ public Long getPetId() {
+ return petId;
+ }
+ public void setPetId(Long petId) {
+ this.petId = petId;
+ }
+
+
+ /**
+ **/
+ @ApiModelProperty(value = "")
+ public Integer getQuantity() {
+ return quantity;
+ }
+ public void setQuantity(Integer quantity) {
+ this.quantity = quantity;
+ }
+
+
+ /**
+ **/
+ @ApiModelProperty(value = "")
+ public Date getShipDate() {
+ return shipDate;
+ }
+ public void setShipDate(Date shipDate) {
+ this.shipDate = shipDate;
+ }
+
+
+ /**
+ * Order Status
+ **/
+ @ApiModelProperty(value = "Order Status")
+ public StatusEnum getStatus() {
+ return status;
+ }
+ public void setStatus(StatusEnum status) {
+ this.status = status;
+ }
+
+
+ /**
+ **/
+ @ApiModelProperty(value = "")
+ public Boolean getComplete() {
+ return complete;
+ }
+ public void setComplete(Boolean complete) {
+ this.complete = complete;
+ }
+
+
+
+ @Override
+ public boolean equals(Object o) {
+ if (this == o) {
+ return true;
+ }
+ if (o == null || getClass() != o.getClass()) {
+ return false;
+ }
+ Order order = (Order) o;
+ return Objects.equals(id, order.id) &&
+ Objects.equals(petId, order.petId) &&
+ Objects.equals(quantity, order.quantity) &&
+ Objects.equals(shipDate, order.shipDate) &&
+ Objects.equals(status, order.status) &&
+ Objects.equals(complete, order.complete);
+ }
+
+ @Override
+ public int hashCode() {
+ return Objects.hash(id, petId, quantity, shipDate, status, complete);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder();
+ sb.append("class Order {\n");
+
+ sb.append(" id: ").append(toIndentedString(id)).append("\n");
+ sb.append(" petId: ").append(toIndentedString(petId)).append("\n");
+ sb.append(" quantity: ").append(toIndentedString(quantity)).append("\n");
+ sb.append(" shipDate: ").append(toIndentedString(shipDate)).append("\n");
+ sb.append(" status: ").append(toIndentedString(status)).append("\n");
+ sb.append(" complete: ").append(toIndentedString(complete)).append("\n");
+ sb.append("}");
+ return sb.toString();
+ }
+
+ /**
+ * Convert the given object to string with each line indented by 4 spaces
+ * (except the first line).
+ */
+ private String toIndentedString(Object o) {
+ if (o == null) {
+ return "null";
+ }
+ return o.toString().replace("\n", "\n ");
+ }
+}
diff --git a/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/model/Pet.java b/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/model/Pet.java
new file mode 100644
index 00000000000..1f9462ddc3a
--- /dev/null
+++ b/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/model/Pet.java
@@ -0,0 +1,176 @@
+package io.swagger.client.model;
+
+import java.util.Objects;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import io.swagger.client.model.Category;
+import io.swagger.client.model.Tag;
+import java.util.*;
+
+import com.google.gson.annotations.SerializedName;
+
+
+
+
+@ApiModel(description = "")
+public class Pet {
+
+ @SerializedName("id")
+ private Long id = null;
+
+ @SerializedName("category")
+ private Category category = null;
+
+ @SerializedName("name")
+ private String name = null;
+
+ @SerializedName("photoUrls")
+ private List photoUrls = new ArrayList();
+
+ @SerializedName("tags")
+ private List tags = new ArrayList();
+
+
+public enum StatusEnum {
+ @SerializedName("available")
+ AVAILABLE("available"),
+
+ @SerializedName("pending")
+ PENDING("pending"),
+
+ @SerializedName("sold")
+ SOLD("sold");
+
+ private String value;
+
+ StatusEnum(String value) {
+ this.value = value;
+ }
+
+ @Override
+ public String toString() {
+ return value;
+ }
+}
+
+ @SerializedName("status")
+ private StatusEnum status = null;
+
+
+
+ /**
+ **/
+ @ApiModelProperty(value = "")
+ public Long getId() {
+ return id;
+ }
+ public void setId(Long id) {
+ this.id = id;
+ }
+
+
+ /**
+ **/
+ @ApiModelProperty(value = "")
+ public Category getCategory() {
+ return category;
+ }
+ public void setCategory(Category category) {
+ this.category = category;
+ }
+
+
+ /**
+ **/
+ @ApiModelProperty(required = true, value = "")
+ public String getName() {
+ return name;
+ }
+ public void setName(String name) {
+ this.name = name;
+ }
+
+
+ /**
+ **/
+ @ApiModelProperty(required = true, value = "")
+ public List getPhotoUrls() {
+ return photoUrls;
+ }
+ public void setPhotoUrls(List photoUrls) {
+ this.photoUrls = photoUrls;
+ }
+
+
+ /**
+ **/
+ @ApiModelProperty(value = "")
+ public List getTags() {
+ return tags;
+ }
+ public void setTags(List tags) {
+ this.tags = tags;
+ }
+
+
+ /**
+ * pet status in the store
+ **/
+ @ApiModelProperty(value = "pet status in the store")
+ public StatusEnum getStatus() {
+ return status;
+ }
+ public void setStatus(StatusEnum status) {
+ this.status = status;
+ }
+
+
+
+ @Override
+ public boolean equals(Object o) {
+ if (this == o) {
+ return true;
+ }
+ if (o == null || getClass() != o.getClass()) {
+ return false;
+ }
+ Pet pet = (Pet) o;
+ return Objects.equals(id, pet.id) &&
+ Objects.equals(category, pet.category) &&
+ Objects.equals(name, pet.name) &&
+ Objects.equals(photoUrls, pet.photoUrls) &&
+ Objects.equals(tags, pet.tags) &&
+ Objects.equals(status, pet.status);
+ }
+
+ @Override
+ public int hashCode() {
+ return Objects.hash(id, category, name, photoUrls, tags, status);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder();
+ sb.append("class Pet {\n");
+
+ sb.append(" id: ").append(toIndentedString(id)).append("\n");
+ sb.append(" category: ").append(toIndentedString(category)).append("\n");
+ sb.append(" name: ").append(toIndentedString(name)).append("\n");
+ sb.append(" photoUrls: ").append(toIndentedString(photoUrls)).append("\n");
+ sb.append(" tags: ").append(toIndentedString(tags)).append("\n");
+ sb.append(" status: ").append(toIndentedString(status)).append("\n");
+ sb.append("}");
+ return sb.toString();
+ }
+
+ /**
+ * Convert the given object to string with each line indented by 4 spaces
+ * (except the first line).
+ */
+ private String toIndentedString(Object o) {
+ if (o == null) {
+ return "null";
+ }
+ return o.toString().replace("\n", "\n ");
+ }
+}
diff --git a/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/model/Tag.java b/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/model/Tag.java
new file mode 100644
index 00000000000..a4ca1074ca1
--- /dev/null
+++ b/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/model/Tag.java
@@ -0,0 +1,85 @@
+package io.swagger.client.model;
+
+import java.util.Objects;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+
+import com.google.gson.annotations.SerializedName;
+
+
+
+
+@ApiModel(description = "")
+public class Tag {
+
+ @SerializedName("id")
+ private Long id = null;
+
+ @SerializedName("name")
+ private String name = null;
+
+
+
+ /**
+ **/
+ @ApiModelProperty(value = "")
+ public Long getId() {
+ return id;
+ }
+ public void setId(Long id) {
+ this.id = id;
+ }
+
+
+ /**
+ **/
+ @ApiModelProperty(value = "")
+ public String getName() {
+ return name;
+ }
+ public void setName(String name) {
+ this.name = name;
+ }
+
+
+
+ @Override
+ public boolean equals(Object o) {
+ if (this == o) {
+ return true;
+ }
+ if (o == null || getClass() != o.getClass()) {
+ return false;
+ }
+ Tag tag = (Tag) o;
+ return Objects.equals(id, tag.id) &&
+ Objects.equals(name, tag.name);
+ }
+
+ @Override
+ public int hashCode() {
+ return Objects.hash(id, name);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder();
+ sb.append("class Tag {\n");
+
+ sb.append(" id: ").append(toIndentedString(id)).append("\n");
+ sb.append(" name: ").append(toIndentedString(name)).append("\n");
+ sb.append("}");
+ return sb.toString();
+ }
+
+ /**
+ * Convert the given object to string with each line indented by 4 spaces
+ * (except the first line).
+ */
+ private String toIndentedString(Object o) {
+ if (o == null) {
+ return "null";
+ }
+ return o.toString().replace("\n", "\n ");
+ }
+}
diff --git a/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/model/User.java b/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/model/User.java
new file mode 100644
index 00000000000..072f510081a
--- /dev/null
+++ b/samples/client/petstore/java/retrofit2rx/src/main/java/io/swagger/client/model/User.java
@@ -0,0 +1,182 @@
+package io.swagger.client.model;
+
+import java.util.Objects;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+
+import com.google.gson.annotations.SerializedName;
+
+
+
+
+@ApiModel(description = "")
+public class User {
+
+ @SerializedName("id")
+ private Long id = null;
+
+ @SerializedName("username")
+ private String username = null;
+
+ @SerializedName("firstName")
+ private String firstName = null;
+
+ @SerializedName("lastName")
+ private String lastName = null;
+
+ @SerializedName("email")
+ private String email = null;
+
+ @SerializedName("password")
+ private String password = null;
+
+ @SerializedName("phone")
+ private String phone = null;
+
+ @SerializedName("userStatus")
+ private Integer userStatus = null;
+
+
+
+ /**
+ **/
+ @ApiModelProperty(value = "")
+ public Long getId() {
+ return id;
+ }
+ public void setId(Long id) {
+ this.id = id;
+ }
+
+
+ /**
+ **/
+ @ApiModelProperty(value = "")
+ public String getUsername() {
+ return username;
+ }
+ public void setUsername(String username) {
+ this.username = username;
+ }
+
+
+ /**
+ **/
+ @ApiModelProperty(value = "")
+ public String getFirstName() {
+ return firstName;
+ }
+ public void setFirstName(String firstName) {
+ this.firstName = firstName;
+ }
+
+
+ /**
+ **/
+ @ApiModelProperty(value = "")
+ public String getLastName() {
+ return lastName;
+ }
+ public void setLastName(String lastName) {
+ this.lastName = lastName;
+ }
+
+
+ /**
+ **/
+ @ApiModelProperty(value = "")
+ public String getEmail() {
+ return email;
+ }
+ public void setEmail(String email) {
+ this.email = email;
+ }
+
+
+ /**
+ **/
+ @ApiModelProperty(value = "")
+ public String getPassword() {
+ return password;
+ }
+ public void setPassword(String password) {
+ this.password = password;
+ }
+
+
+ /**
+ **/
+ @ApiModelProperty(value = "")
+ public String getPhone() {
+ return phone;
+ }
+ public void setPhone(String phone) {
+ this.phone = phone;
+ }
+
+
+ /**
+ * User Status
+ **/
+ @ApiModelProperty(value = "User Status")
+ public Integer getUserStatus() {
+ return userStatus;
+ }
+ public void setUserStatus(Integer userStatus) {
+ this.userStatus = userStatus;
+ }
+
+
+
+ @Override
+ public boolean equals(Object o) {
+ if (this == o) {
+ return true;
+ }
+ if (o == null || getClass() != o.getClass()) {
+ return false;
+ }
+ User user = (User) o;
+ return Objects.equals(id, user.id) &&
+ Objects.equals(username, user.username) &&
+ Objects.equals(firstName, user.firstName) &&
+ Objects.equals(lastName, user.lastName) &&
+ Objects.equals(email, user.email) &&
+ Objects.equals(password, user.password) &&
+ Objects.equals(phone, user.phone) &&
+ Objects.equals(userStatus, user.userStatus);
+ }
+
+ @Override
+ public int hashCode() {
+ return Objects.hash(id, username, firstName, lastName, email, password, phone, userStatus);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder();
+ sb.append("class User {\n");
+
+ sb.append(" id: ").append(toIndentedString(id)).append("\n");
+ sb.append(" username: ").append(toIndentedString(username)).append("\n");
+ sb.append(" firstName: ").append(toIndentedString(firstName)).append("\n");
+ sb.append(" lastName: ").append(toIndentedString(lastName)).append("\n");
+ sb.append(" email: ").append(toIndentedString(email)).append("\n");
+ sb.append(" password: ").append(toIndentedString(password)).append("\n");
+ sb.append(" phone: ").append(toIndentedString(phone)).append("\n");
+ sb.append(" userStatus: ").append(toIndentedString(userStatus)).append("\n");
+ sb.append("}");
+ return sb.toString();
+ }
+
+ /**
+ * Convert the given object to string with each line indented by 4 spaces
+ * (except the first line).
+ */
+ private String toIndentedString(Object o) {
+ if (o == null) {
+ return "null";
+ }
+ return o.toString().replace("\n", "\n ");
+ }
+}
diff --git a/samples/client/petstore/java/retrofit2rx/src/test/java/io/swagger/petstore/test/PetApiTest.java b/samples/client/petstore/java/retrofit2rx/src/test/java/io/swagger/petstore/test/PetApiTest.java
new file mode 100644
index 00000000000..7b010e76051
--- /dev/null
+++ b/samples/client/petstore/java/retrofit2rx/src/test/java/io/swagger/petstore/test/PetApiTest.java
@@ -0,0 +1,214 @@
+package io.swagger.petstore.test;
+
+import io.swagger.client.ApiClient;
+import io.swagger.client.api.*;
+import io.swagger.client.model.*;
+
+import java.io.BufferedWriter;
+import java.io.File;
+import java.io.FileWriter;
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+
+import org.junit.*;
+
+import rx.Notification;
+import rx.Observable;
+
+import com.squareup.okhttp.MediaType;
+import com.squareup.okhttp.RequestBody;
+import rx.Subscriber;
+import rx.functions.Action1;
+import rx.observers.TestSubscriber;
+
+import static org.junit.Assert.*;
+
+public class PetApiTest {
+ PetApi api = null;
+
+ @Before
+ public void setup() {
+ api = new ApiClient().createService(PetApi.class);
+ }
+
+ @Test
+ public void testCreateAndGetPet() throws Exception {
+ final Pet pet = createRandomPet();
+ api.addPet(pet).subscribe(aVoid -> {
+ api.getPetById(pet.getId()).subscribe(fetched -> {
+ assertNotNull(fetched);
+ assertEquals(pet.getId(), fetched.getId());
+ assertNotNull(fetched.getCategory());
+ assertEquals(fetched.getCategory().getName(), pet.getCategory().getName());
+ });
+ });
+ }
+
+ @Test
+ public void testUpdatePet() throws Exception {
+ final Pet pet = createRandomPet();
+ pet.setName("programmer");
+
+ api.updatePet(pet).subscribe(aVoid -> {
+ api.getPetById(pet.getId()).subscribe(fetched -> {
+ assertNotNull(fetched);
+ assertEquals(pet.getId(), fetched.getId());
+ assertNotNull(fetched.getCategory());
+ assertEquals(fetched.getCategory().getName(), pet.getCategory().getName());
+ });
+ });
+ }
+
+ @Test
+ public void testFindPetsByStatus() throws Exception {
+ final Pet pet = createRandomPet();
+ pet.setName("programmer");
+ pet.setStatus(Pet.StatusEnum.AVAILABLE);
+
+ api.updatePet(pet).subscribe(aVoid -> {
+ api.findPetsByStatus(Arrays.asList(new String[]{"available"})).subscribe(pets -> {
+ assertNotNull(pets);
+
+ boolean found = false;
+ for (Pet fetched : pets) {
+ if (fetched.getId().equals(pet.getId())) {
+ found = true;
+ break;
+ }
+ }
+
+ assertTrue(found);
+ });
+ });
+ }
+
+ @Test
+ public void testFindPetsByTags() throws Exception {
+ final Pet pet = createRandomPet();
+ pet.setName("monster");
+ pet.setStatus(Pet.StatusEnum.AVAILABLE);
+
+ List tags = new ArrayList();
+ Tag tag1 = new Tag();
+ tag1.setName("friendly");
+ tags.add(tag1);
+ pet.setTags(tags);
+
+ api.updatePet(pet).subscribe(aVoid -> {
+ api.findPetsByTags(Arrays.asList(new String[]{"friendly"})).subscribe(pets -> {
+ assertNotNull(pets);
+
+ boolean found = false;
+ for (Pet fetched : pets) {
+ if (fetched.getId().equals(pet.getId())) {
+ found = true;
+ break;
+ }
+ }
+ assertTrue(found);
+ });
+ });
+ }
+
+ @Test
+ public void testUpdatePetWithForm() throws Exception {
+ final Pet pet = createRandomPet();
+ pet.setName("frank");
+ api.addPet(pet).subscribe(aVoid1 -> {
+ api.getPetById(pet.getId()).subscribe(fetched -> {
+ api.updatePetWithForm(String.valueOf(fetched.getId()), "furt", null)
+ .subscribe(aVoid -> {
+ api.getPetById(fetched.getId()).subscribe(updated -> {
+ assertEquals(updated.getName(), "furt");
+ });
+ });
+ });
+ });
+ }
+
+ @Test
+ public void testDeletePet() throws Exception {
+ Pet pet = createRandomPet();
+ api.addPet(pet).subscribe(aVoid -> {
+ });
+
+ api.getPetById(pet.getId()).subscribe(fetched -> {
+ api.deletePet(fetched.getId(), null).subscribe(aVoid -> {
+ api.getPetById(fetched.getId()).subscribe(
+ deletedPet -> {
+ fail("Should not have found deleted pet.");
+ },
+ exception -> {
+ // expected, because the pet has been deleted.
+ });
+
+ });
+ });
+ }
+
+ @Test
+ public void testUploadFile() throws Exception {
+ File file = File.createTempFile("test", "hello.txt");
+ BufferedWriter writer = new BufferedWriter(new FileWriter(file));
+
+ writer.write("Hello world!");
+ writer.close();
+
+ Pet pet = createRandomPet();
+ api.addPet(pet).subscribe(aVoid -> {
+ RequestBody body = RequestBody.create(MediaType.parse("text/plain"), file);
+ api.uploadFile(pet.getId(), "a test file", body).subscribe(
+ aVoid1 -> {
+ // intentionally left blank.
+ },
+ error -> {
+ // this also yields a 400 for other tests, so I guess it's okay...
+ });
+ });
+ }
+
+ @Test
+ public void testEqualsAndHashCode() {
+ Pet pet1 = new Pet();
+ Pet pet2 = new Pet();
+ assertTrue(pet1.equals(pet2));
+ assertTrue(pet2.equals(pet1));
+ assertTrue(pet1.hashCode() == pet2.hashCode());
+ assertTrue(pet1.equals(pet1));
+ assertTrue(pet1.hashCode() == pet1.hashCode());
+
+ pet2.setName("really-happy");
+ pet2.setPhotoUrls(Arrays.asList(new String[]{"http://foo.bar.com/1", "http://foo.bar.com/2"}));
+ assertFalse(pet1.equals(pet2));
+ assertFalse(pet2.equals(pet1));
+ assertFalse(pet1.hashCode() == (pet2.hashCode()));
+ assertTrue(pet2.equals(pet2));
+ assertTrue(pet2.hashCode() == pet2.hashCode());
+
+ pet1.setName("really-happy");
+ pet1.setPhotoUrls(Arrays.asList(new String[]{"http://foo.bar.com/1", "http://foo.bar.com/2"}));
+ assertTrue(pet1.equals(pet2));
+ assertTrue(pet2.equals(pet1));
+ assertTrue(pet1.hashCode() == pet2.hashCode());
+ assertTrue(pet1.equals(pet1));
+ assertTrue(pet1.hashCode() == pet1.hashCode());
+ }
+
+ private Pet createRandomPet() {
+ Pet pet = new Pet();
+ pet.setId(System.currentTimeMillis());
+ pet.setName("gorilla");
+
+ Category category = new Category();
+ category.setName("really-happy");
+
+ pet.setCategory(category);
+ pet.setStatus(Pet.StatusEnum.AVAILABLE);
+ List photos = Arrays.asList(new String[]{"http://foo.bar.com/1", "http://foo.bar.com/2"});
+ pet.setPhotoUrls(photos);
+
+ return pet;
+ }
+}
\ No newline at end of file
diff --git a/samples/client/petstore/java/retrofit2rx/src/test/java/io/swagger/petstore/test/StoreApiTest.java b/samples/client/petstore/java/retrofit2rx/src/test/java/io/swagger/petstore/test/StoreApiTest.java
new file mode 100644
index 00000000000..9dacaced7b6
--- /dev/null
+++ b/samples/client/petstore/java/retrofit2rx/src/test/java/io/swagger/petstore/test/StoreApiTest.java
@@ -0,0 +1,71 @@
+package io.swagger.petstore.test;
+
+import io.swagger.client.ApiClient;
+import io.swagger.client.api.*;
+import io.swagger.client.model.*;
+
+import java.util.Map;
+
+import org.junit.*;
+
+import retrofit.Response;
+import static org.junit.Assert.*;
+
+public class StoreApiTest {
+ StoreApi api = null;
+
+ @Before
+ public void setup() {
+ api = new ApiClient().createService(StoreApi.class);
+ }
+
+ @Test
+ public void testGetInventory() throws Exception {
+ api.getInventory().subscribe(inventory -> {
+ assertTrue(inventory.keySet().size() > 0);
+ });
+ }
+
+ @Test
+ public void testPlaceOrder() throws Exception {
+ Order order = createOrder();
+ api.placeOrder(order).subscribe(placed -> {});
+ api.getOrderById(String.valueOf(order.getId())).subscribe(fetched -> {
+ assertEquals(order.getId(), fetched.getId());
+ assertEquals(order.getPetId(), fetched.getPetId());
+ assertEquals(order.getQuantity(), fetched.getQuantity());
+ });
+ }
+
+ @Test
+ public void testDeleteOrder() throws Exception {
+ Order order = createOrder();
+ api.placeOrder(order).subscribe(order1 -> {
+ });
+
+ api.getOrderById(String.valueOf(order.getId())).subscribe(fetched -> {
+ assertEquals(fetched.getId(), order.getId());
+ });
+
+ api.deleteOrder(String.valueOf(order.getId())).subscribe(aVoid -> {
+ });
+ api.getOrderById(String.valueOf(order.getId())).subscribe(
+ order1 -> {
+ throw new RuntimeException("Should not have found deleted order.");
+ },
+ error -> {}
+ );
+ }
+
+ private Order createOrder() {
+ Order order = new Order();
+ order.setId(new Long(System.currentTimeMillis()));
+ order.setPetId(new Long(200));
+ order.setQuantity(new Integer(13));
+ order.setShipDate(new java.util.Date());
+ order.setStatus(Order.StatusEnum.PLACED);
+ order.setComplete(true);
+
+ return order;
+ }
+}
\ No newline at end of file
diff --git a/samples/client/petstore/java/retrofit2rx/src/test/java/io/swagger/petstore/test/UserApiTest.java b/samples/client/petstore/java/retrofit2rx/src/test/java/io/swagger/petstore/test/UserApiTest.java
new file mode 100644
index 00000000000..b72918ab380
--- /dev/null
+++ b/samples/client/petstore/java/retrofit2rx/src/test/java/io/swagger/petstore/test/UserApiTest.java
@@ -0,0 +1,88 @@
+package io.swagger.petstore.test;
+
+import io.swagger.client.ApiClient;
+import io.swagger.client.api.*;
+import io.swagger.client.model.*;
+
+
+import java.util.Arrays;
+
+import org.junit.*;
+import static org.junit.Assert.*;
+
+public class UserApiTest {
+ UserApi api = null;
+
+ @Before
+ public void setup() {
+ api = new ApiClient().createService(UserApi.class);
+ }
+
+ @Test
+ public void testCreateUser() throws Exception {
+ User user = createUser();
+
+ api.createUser(user).subscribe(aVoid -> {
+ api.getUserByName(user.getUsername()).subscribe(fetched -> {
+ assertEquals(user.getId(), fetched.getId());
+ });
+ });
+ }
+
+ @Test
+ public void testCreateUsersWithArray() throws Exception {
+ User user1 = createUser();
+ user1.setUsername("abc123");
+ User user2 = createUser();
+ user2.setUsername("123abc");
+
+ api.createUsersWithArrayInput(Arrays.asList(new User[]{user1, user2})).subscribe(aVoid -> {});
+
+ api.getUserByName(user1.getUsername()).subscribe(fetched -> {
+ assertEquals(user1.getId(), fetched.getId());
+ });
+ }
+
+ @Test
+ public void testCreateUsersWithList() throws Exception {
+ User user1 = createUser();
+ user1.setUsername("abc123");
+ User user2 = createUser();
+ user2.setUsername("123abc");
+
+ api.createUsersWithListInput(Arrays.asList(new User[]{user1, user2})).subscribe(aVoid -> {});
+
+ api.getUserByName(user1.getUsername()).subscribe(fetched -> {
+ assertEquals(user1.getId(), fetched.getId());
+ });
+ }
+
+ @Test
+ public void testLoginUser() throws Exception {
+ User user = createUser();
+ api.createUser(user);
+
+ api.loginUser(user.getUsername(), user.getPassword()).subscribe(token -> {
+ assertTrue(token.startsWith("logged in user session:"));
+ });
+ }
+
+ @Test
+ public void logoutUser() throws Exception {
+ api.logoutUser();
+ }
+
+ private User createUser() {
+ User user = new User();
+ user.setId(System.currentTimeMillis());
+ user.setUsername("fred");
+ user.setFirstName("Fred");
+ user.setLastName("Meyer");
+ user.setEmail("fred@fredmeyer.com");
+ user.setPassword("xxXXxx");
+ user.setPhone("408-867-5309");
+ user.setUserStatus(123);
+
+ return user;
+ }
+}
\ No newline at end of file