Remove usage of parallelStream in favor of stream

Author: zack13532

gradle.properties

@@ -1,2 +1,2 @@
-version=0.9.2-SNAPSHOT
+version=0.9.3-SNAPSHOT
 ossrh.username=tecton-team

src/main/java/ai/tecton/client/request/GetFeaturesBatchRequest.java

@@ -198,8 +198,7 @@ public GetFeaturesBatchRequest(
       // For batch requests, partition the requestDataList into n sublists of size
       // microBatchSize and create GetFeaturesMicroBatchRequest for each
       this.requestList =
-          ListUtils.partition(requestDataList, microBatchSize)
-              .parallelStream()
+          ListUtils.partition(requestDataList, microBatchSize).stream()
               .map(
                   requestData ->
                       new GetFeaturesMicroBatchRequest(
@@ -212,8 +211,7 @@ public GetFeaturesBatchRequest(
     } else {
       // For microBatchSize=1, create a List of individual GetFeaturesRequest objects
       this.requestList =
-          requestDataList
-              .parallelStream()
+          requestDataList.stream()
               .map(
                   requestData ->
                       new GetFeaturesRequest(
@@ -400,7 +398,7 @@ private static void validateParameters(
     if (requestDataList == null || requestDataList.isEmpty()) {
       throw new InvalidRequestParameterException(TectonErrorMessage.INVALID_REQUEST_DATA_LIST);
     }
-    requestDataList.parallelStream().forEach(AbstractGetFeaturesRequest::validateRequestParameters);
+    requestDataList.forEach(AbstractGetFeaturesRequest::validateRequestParameters);
     if (microBatchSize > RequestConstants.MAX_MICRO_BATCH_SIZE || microBatchSize < 1) {
       throw new InvalidRequestParameterException(
           String.format(

src/main/java/ai/tecton/client/response/GetFeaturesBatchResponse.java

@@ -49,16 +49,14 @@ public GetFeaturesBatchResponse(
 
     // Serialize list of HttpResponse into list of GetFeaturesMicroBatchResponse
     List<GetFeaturesMicroBatchResponse> microBatchResponses =
-        httpResponseList
-            .parallelStream()
+        httpResponseList.stream()
             .map(httpResponse -> parseSingleHttpResponse(httpResponse, microBatchSize))
             .collect(Collectors.toList());
 
     // Concatenate list of GetFeaturesResponse objects from each microbatch into a single list
     // Maintain ordering
     this.batchResponseList =
-        microBatchResponses
-            .parallelStream()
+        microBatchResponses.stream()
             .map(microBatch -> microBatch.microBatchResponseList)
             .flatMap(List::stream)
             .collect(Collectors.toList());

src/main/java/ai/tecton/client/transport/TectonHttpClient.java

@@ -114,8 +114,7 @@ public List<HttpResponse> performParallelRequests(
     // Map request body to OkHttp Request
     // ordering of requests is maintained
     List<Request> requestList =
-        requestBodyList
-            .parallelStream()
+        requestBodyList.stream()
             .map(
                 requestBody ->
                     new HttpRequest(url.url().toString(), endpoint, method, apiKey, requestBody))
@@ -153,12 +152,10 @@ public void onResponse(Call call, Response response) {
         };
 
     // Enqueue all calls
-    requestList
-        .parallelStream()
-        .forEach(
-            request -> {
-              client.newCall(request).enqueue(callback);
-            });
+    requestList.forEach(
+        request -> {
+          client.newCall(request).enqueue(callback);
+        });
 
     // Wait until A) all calls have completed or B) specified timeout has elapsed
     try {