Skip to content

Commit 1ed9849

Browse files
ferhatelmasferhatelmas
authored
Fix lambda warnings (#85)
1 parent bb2b58d commit 1ed9849

File tree

4 files changed

+25
-21
lines changed

4 files changed

+25
-21
lines changed

‎src/main/java/io/getstream/cloud/CloudAggregatedFeed.java‎

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@
33
import static io.getstream.core.utils.Serialization.deserializeContainer;
44

55
import io.getstream.core.exceptions.StreamException;
6+
import io.getstream.core.http.Response;
67
import io.getstream.core.models.Activity;
78
import io.getstream.core.models.EnrichedActivity;
89
import io.getstream.core.models.FeedID;
@@ -109,7 +110,7 @@ CompletableFuture<? extends List<? extends Group<Activity>>> getActivities(
109110
return getClient()
110111
.getActivities(getID(), limit, offset, filter, marker)
111112
.thenApply(
112-
response -> {
113+
(Response response) -> {
113114
try {
114115
return deserializeContainer(response, Group.class, Activity.class);
115116
} catch (StreamException | IOException e) {
@@ -214,7 +215,7 @@ <T> CompletableFuture<? extends List<? extends Group<T>>> getCustomActivities(
214215
return getClient()
215216
.getActivities(getID(), limit, offset, filter, marker)
216217
.thenApply(
217-
response -> {
218+
(Response response) -> {
218219
try {
219220
return deserializeContainer(response, Group.class, type);
220221
} catch (StreamException | IOException e) {
@@ -441,7 +442,7 @@ CompletableFuture<? extends List<? extends Group<EnrichedActivity>>> getEnriched
441442
return getClient()
442443
.getEnrichedActivities(getID(), limit, offset, filter, marker, flags)
443444
.thenApply(
444-
response -> {
445+
(Response response) -> {
445446
try {
446447
return deserializeContainer(response, Group.class, EnrichedActivity.class);
447448
} catch (StreamException | IOException e) {
@@ -695,7 +696,7 @@ <T> CompletableFuture<? extends List<? extends Group<T>>> getEnrichedCustomActiv
695696
return getClient()
696697
.getEnrichedActivities(getID(), limit, offset, filter, marker, flags)
697698
.thenApply(
698-
response -> {
699+
(Response response) -> {
699700
try {
700701
return deserializeContainer(response, Group.class, type);
701702
} catch (StreamException | IOException e) {

‎src/main/java/io/getstream/cloud/CloudFeed.java‎

Lines changed: 10 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@
66

77
import com.google.common.collect.Iterables;
88
import io.getstream.core.exceptions.StreamException;
9+
import io.getstream.core.http.Response;
910
import io.getstream.core.models.Activity;
1011
import io.getstream.core.models.FeedID;
1112
import io.getstream.core.models.FollowRelation;
@@ -90,7 +91,7 @@ public final <T> CompletableFuture<List<T>> addCustomActivities(Iterable<T> acti
9091
return getClient()
9192
.addActivities(id, custom)
9293
.thenApply(
93-
response -> {
94+
(Response response) -> {
9495
try {
9596
Class<T> element =
9697
(Class<T>)
@@ -108,7 +109,7 @@ public final CompletableFuture<List<Activity>> addActivities(Activity... activit
108109
return getClient()
109110
.addActivities(id, activities)
110111
.thenApply(
111-
response -> {
112+
(Response response) -> {
112113
try {
113114
return deserializeContainer(response, "activities", Activity.class);
114115
} catch (StreamException | IOException e) {
@@ -126,7 +127,7 @@ public final <T> CompletableFuture<List<T>> addCustomActivities(T... activities)
126127
return getClient()
127128
.addActivities(id, custom)
128129
.thenApply(
129-
response -> {
130+
(Response response) -> {
130131
try {
131132
Class<T> element = (Class<T>) activities.getClass().getComponentType();
132133
return deserializeContainer(response, "activities", element);
@@ -140,7 +141,7 @@ public final CompletableFuture<Void> removeActivityByID(String id) throws Stream
140141
return client
141142
.removeActivityByID(this.id, id)
142143
.thenApply(
143-
response -> {
144+
(Response response) -> {
144145
try {
145146
return deserializeError(response);
146147
} catch (StreamException | IOException e) {
@@ -154,7 +155,7 @@ public final CompletableFuture<Void> removeActivityByForeignID(String foreignID)
154155
return client
155156
.removeActivityByForeignID(id, foreignID)
156157
.thenApply(
157-
response -> {
158+
(Response response) -> {
158159
try {
159160
return deserializeError(response);
160161
} catch (StreamException | IOException e) {
@@ -177,7 +178,7 @@ public final CompletableFuture<Void> follow(CloudFlatFeed feed, int activityCopy
177178
return client
178179
.follow(id, feed.getID(), activityCopyLimit)
179180
.thenApply(
180-
response -> {
181+
(Response response) -> {
181182
try {
182183
return deserializeError(response);
183184
} catch (StreamException | IOException e) {
@@ -240,7 +241,7 @@ limit, offset, new CustomQueryParameter("filter", String.join(",", feedIDs))
240241
return client
241242
.getFollowers(id, options)
242243
.thenApply(
243-
response -> {
244+
(Response response) -> {
244245
try {
245246
return deserializeContainer(response, FollowRelation.class);
246247
} catch (StreamException | IOException e) {
@@ -303,7 +304,7 @@ limit, offset, new CustomQueryParameter("filter", String.join(",", feedIDs))
303304
return client
304305
.getFollowed(id, options)
305306
.thenApply(
306-
response -> {
307+
(Response response) -> {
307308
try {
308309
return deserializeContainer(response, FollowRelation.class);
309310
} catch (StreamException | IOException e) {
@@ -321,7 +322,7 @@ public final CompletableFuture<Void> unfollow(
321322
return client
322323
.unfollow(id, feed.getID(), new io.getstream.core.options.KeepHistory(keepHistory))
323324
.thenApply(
324-
response -> {
325+
(Response response) -> {
325326
try {
326327
return deserializeError(response);
327328
} catch (StreamException | IOException e) {

‎src/main/java/io/getstream/cloud/CloudFlatFeed.java‎

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@
33
import static io.getstream.core.utils.Serialization.deserializeContainer;
44

55
import io.getstream.core.exceptions.StreamException;
6+
import io.getstream.core.http.Response;
67
import io.getstream.core.models.Activity;
78
import io.getstream.core.models.EnrichedActivity;
89
import io.getstream.core.models.FeedID;
@@ -95,7 +96,7 @@ limit, offset, filter, DefaultOptions.DEFAULT_MARKER, new Ranking(ranking)
9596
return getClient()
9697
.getActivities(getID(), options)
9798
.thenApply(
98-
response -> {
99+
(Response response) -> {
99100
try {
100101
return deserializeContainer(response, Activity.class);
101102
} catch (StreamException | IOException e) {
@@ -191,7 +192,7 @@ limit, offset, filter, DefaultOptions.DEFAULT_MARKER, new Ranking(ranking)
191192
return getClient()
192193
.getActivities(getID(), options)
193194
.thenApply(
194-
response -> {
195+
(Response response) -> {
195196
try {
196197
return deserializeContainer(response, type);
197198
} catch (StreamException | IOException e) {
@@ -407,7 +408,7 @@ limit, offset, filter, flags, DefaultOptions.DEFAULT_MARKER, new Ranking(ranking
407408
return getClient()
408409
.getEnrichedActivities(getID(), options)
409410
.thenApply(
410-
response -> {
411+
(Response response) -> {
411412
try {
412413
return deserializeContainer(response, EnrichedActivity.class);
413414
} catch (StreamException | IOException e) {
@@ -649,7 +650,7 @@ limit, offset, filter, flags, DefaultOptions.DEFAULT_MARKER, new Ranking(ranking
649650
return getClient()
650651
.getActivities(getID(), options)
651652
.thenApply(
652-
response -> {
653+
(Response response) -> {
653654
try {
654655
return deserializeContainer(response, type);
655656
} catch (StreamException | IOException e) {

‎src/main/java/io/getstream/cloud/CloudNotificationFeed.java‎

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@
33
import static io.getstream.core.utils.Serialization.deserializeContainer;
44

55
import io.getstream.core.exceptions.StreamException;
6+
import io.getstream.core.http.Response;
67
import io.getstream.core.models.Activity;
78
import io.getstream.core.models.EnrichedActivity;
89
import io.getstream.core.models.FeedID;
@@ -122,7 +123,7 @@ CompletableFuture<List<NotificationGroup<Activity>>> getActivities(
122123
return getClient()
123124
.getActivities(getID(), limit, offset, filter, marker)
124125
.thenApply(
125-
response -> {
126+
(Response response) -> {
126127
try {
127128
return deserializeContainer(response, NotificationGroup.class, Activity.class);
128129
} catch (StreamException | IOException e) {
@@ -240,7 +241,7 @@ <T> CompletableFuture<List<NotificationGroup<T>>> getCustomActivities(
240241
return getClient()
241242
.getActivities(getID(), limit, offset, filter, marker)
242243
.thenApply(
243-
response -> {
244+
(Response response) -> {
244245
try {
245246
return deserializeContainer(response, NotificationGroup.class, type);
246247
} catch (StreamException | IOException e) {
@@ -492,7 +493,7 @@ CompletableFuture<List<NotificationGroup<EnrichedActivity>>> getEnrichedActiviti
492493
return getClient()
493494
.getEnrichedActivities(getID(), limit, offset, filter, marker, flags)
494495
.thenApply(
495-
response -> {
496+
(Response response) -> {
496497
try {
497498
return deserializeContainer(
498499
response, NotificationGroup.class, EnrichedActivity.class);
@@ -772,7 +773,7 @@ <T> CompletableFuture<List<NotificationGroup<T>>> getEnrichedCustomActivities(
772773
return getClient()
773774
.getEnrichedActivities(getID(), limit, offset, filter, marker, flags)
774775
.thenApply(
775-
response -> {
776+
(Response response) -> {
776777
try {
777778
return deserializeContainer(response, NotificationGroup.class, type);
778779
} catch (StreamException | IOException e) {

0 commit comments

Comments
 (0)