Skip to content

Commit 047f313

Browse files
Remove jetbrains @NotNull usage
1 parent 12df626 commit 047f313

4 files changed

Lines changed: 11 additions & 14 deletions

File tree

client/src/main/java/dev/restate/client/base/BaseClient.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,6 @@
3030
import java.util.stream.Stream;
3131
import org.apache.logging.log4j.LogManager;
3232
import org.apache.logging.log4j.Logger;
33-
import org.jetbrains.annotations.NotNull;
3433
import org.jspecify.annotations.NonNull;
3534
import org.jspecify.annotations.Nullable;
3635

@@ -358,7 +357,7 @@ protected abstract <Res> CompletableFuture<Res> doPostRequest(
358357
protected abstract <Res> CompletableFuture<Res> doGetRequest(
359358
URI target, Stream<Map.Entry<String, String>> headers, ResponseMapper<Res> responseMapper);
360359

361-
private <Res> @NotNull ResponseMapper<Response<Res>> callResponseMapper(
360+
private <Res> @NonNull ResponseMapper<Response<Res>> callResponseMapper(
362361
String requestMethod, URI requestUri, Serde<Res> resSerde) {
363362
return (statusCode, responseHeaders, responseBody) -> {
364363
if (statusCode >= 300) {
@@ -389,7 +388,7 @@ protected abstract <Res> CompletableFuture<Res> doGetRequest(
389388
};
390389
}
391390

392-
private <Res> @NotNull ResponseMapper<Response<Output<Res>>> getOutputResponseMapper(
391+
private <Res> @NonNull ResponseMapper<Response<Output<Res>>> getOutputResponseMapper(
393392
String requestMethod, URI requestUri, Serde<Res> resSerde) {
394393
return (statusCode, responseHeaders, responseBody) -> {
395394
if (statusCode == 470) {

common/src/main/java/dev/restate/serde/Serde.java

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,6 @@
1111
import dev.restate.common.Slice;
1212
import dev.restate.common.function.ThrowingFunction;
1313
import java.util.Objects;
14-
import org.jetbrains.annotations.NotNull;
1514
import org.jspecify.annotations.*;
1615

1716
/**
@@ -72,7 +71,7 @@ public Slice serialize(T value) {
7271
}
7372

7473
@Override
75-
public T deserialize(@NotNull Slice value) {
74+
public T deserialize(@NonNull Slice value) {
7675
return deserializer.asFunction().apply(value.toByteArray());
7776
}
7877
};
@@ -93,7 +92,7 @@ public Slice serialize(T value) {
9392
}
9493

9594
@Override
96-
public T deserialize(@NotNull Slice value) {
95+
public T deserialize(@NonNull Slice value) {
9796
return deserializer.asFunction().apply(value.toByteArray());
9897
}
9998

@@ -112,7 +111,7 @@ public Slice serialize(T value) {
112111
}
113112

114113
@Override
115-
public T deserialize(@NotNull Slice value) {
114+
public T deserialize(@NonNull Slice value) {
116115
return inner.deserialize(value);
117116
}
118117

@@ -132,7 +131,7 @@ public Slice serialize(Void value) {
132131
}
133132

134133
@Override
135-
public Void deserialize(@NotNull Slice value) {
134+
public Void deserialize(@NonNull Slice value) {
136135
return null;
137136
}
138137

@@ -151,7 +150,7 @@ public Slice serialize(byte[] value) {
151150
}
152151

153152
@Override
154-
public byte[] deserialize(@NotNull Slice value) {
153+
public byte[] deserialize(@NonNull Slice value) {
155154
return value.toByteArray();
156155
}
157156
};
@@ -165,7 +164,7 @@ public Slice serialize(Slice value) {
165164
}
166165

167166
@Override
168-
public Slice deserialize(@NotNull Slice value) {
167+
public Slice deserialize(@NonNull Slice value) {
169168
return value;
170169
}
171170
};

sdk-api/src/main/java/dev/restate/sdk/JsonSerdes.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@
2020
import java.io.ByteArrayOutputStream;
2121
import java.io.IOException;
2222
import java.util.Map;
23-
import org.jetbrains.annotations.NotNull;
2423
import org.jspecify.annotations.NonNull;
2524

2625
/**
@@ -192,7 +191,7 @@ public Slice serialize(T value) {
192191
}
193192

194193
@Override
195-
public T deserialize(@NotNull Slice value) {
194+
public T deserialize(@NonNull Slice value) {
196195
ByteArrayInputStream inputStream = new ByteArrayInputStream(value.toByteArray());
197196
try (JsonParser parser = JSON_FACTORY.createParser(inputStream)) {
198197
return deserializer.asFunction().apply(parser);

sdk-core/src/test/java/dev/restate/sdk/core/TestSerdes.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@
1919
import java.io.ByteArrayInputStream;
2020
import java.io.ByteArrayOutputStream;
2121
import java.io.IOException;
22-
import org.jetbrains.annotations.NotNull;
22+
import org.jetbrains.annotations.NonNull;
2323
import org.jspecify.annotations.Nullable;
2424

2525
/**
@@ -125,7 +125,7 @@ public Slice serialize(@Nullable T value) {
125125
}
126126

127127
@Override
128-
public T deserialize(@NotNull Slice value) {
128+
public T deserialize(@NonNull Slice value) {
129129
ByteArrayInputStream inputStream = new ByteArrayInputStream(value.toByteArray());
130130
try (JsonParser parser = JSON_FACTORY.createParser(inputStream)) {
131131
return deserializer.asFunction().apply(parser);

0 commit comments

Comments
 (0)