chore: add generics to remove warnings about raw usage

BenWhitehead · BenWhitehead · commit 84ffb6d432e7 · 2025-03-14T17:38:21.000-04:00
diff --git a/google-cloud-storage/src/main/java/com/google/cloud/storage/ObjectReadSessionStream.java b/google-cloud-storage/src/main/java/com/google/cloud/storage/ObjectReadSessionStream.java
@@ -281,7 +281,7 @@ public void onResponse(BidiReadObjectResponse response) {
           ObjectRangeData d = rangeData.get(i);
           ReadRange readRange = d.getReadRange();
           long id = readRange.getReadId();
-          ObjectReadSessionStreamRead read = state.getOutstandingRead(id);
+          ObjectReadSessionStreamRead<?> read = state.getOutstandingRead(id);
           if (read == null || !read.acceptingBytes()) {
             continue;
           }
@@ -391,7 +391,7 @@ public void onError(Throwable t) {
         for (ReadRangeError rangeError : rangeErrors) {
           Status status = rangeError.getStatus();
           long id = rangeError.getReadId();
-          ObjectReadSessionStreamRead read = state.getOutstandingRead(id);
+          ObjectReadSessionStreamRead<?> read = state.getOutstandingRead(id);
           if (read == null) {
             continue;
           }
@@ -414,7 +414,7 @@ public void onError(Throwable t) {
     private OnSuccess restartReadFromCurrentOffset(long id) {
       return () -> {
         //noinspection resource
-        ObjectReadSessionStreamRead readWithNewId = state.assignNewReadId(id);
+        ObjectReadSessionStreamRead<?> readWithNewId = state.assignNewReadId(id);
         BidiReadObjectRequest requestWithNewReadId =
             BidiReadObjectRequest.newBuilder().addReadRanges(readWithNewId.makeReadRange()).build();
         ObjectReadSessionStream.this.send(requestWithNewReadId);
