Skip to content

Commit c78d2a0

Browse files
Little kotlin fix
1 parent c059f63 commit c78d2a0

File tree

4 files changed

+10
-9
lines changed

4 files changed

+10
-9
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@
1717
import dev.restate.sdk.types.RetryPolicy;
1818
import dev.restate.sdk.types.TerminalException;
1919
import dev.restate.serde.Serde;
20-
import dev.restate.serde.TypeRef;
2120
import dev.restate.serde.TypeTag;
2221
import java.time.Duration;
2322

@@ -445,7 +444,8 @@ default Awaitable<Void> runAsync(ThrowingRunnable runnable) throws TerminalExcep
445444
* service consume from Kafka the responses of given external system interaction by using {@link
446445
* #awakeableHandle(String)}.
447446
*
448-
* @param clazz the response type to use for deserializing the {@link Awakeable} result. When using generic types, use {@link #awakeable(TypeTag)} instead.
447+
* @param clazz the response type to use for deserializing the {@link Awakeable} result. When
448+
* using generic types, use {@link #awakeable(TypeTag)} instead.
449449
* @return the {@link Awakeable} to await on.
450450
* @see Awakeable
451451
*/

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

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

1111
import dev.restate.common.function.ThrowingSupplier;
1212
import dev.restate.sdk.types.InvocationId;
13-
import dev.restate.serde.Serde;
1413
import java.util.Random;
1514
import java.util.UUID;
1615

@@ -22,7 +21,8 @@
2221
* from a set of options. If a cryptographically secure value is needed, please generate that
2322
* externally using {@link Context#run(String, Class, ThrowingSupplier)}.
2423
*
25-
* <p>You <b>MUST NOT</b> use this object inside a {@link Context#run(String, Class, ThrowingSupplier)}/{@link Context#runAsync(String, Class, ThrowingSupplier)}.
24+
* <p>You <b>MUST NOT</b> use this object inside a {@link Context#run(String, Class,
25+
* ThrowingSupplier)}/{@link Context#runAsync(String, Class, ThrowingSupplier)}.
2626
*/
2727
public class RestateRandom extends Random {
2828

test-services/src/main/kotlin/dev/restate/sdk/testservices/ListObjectImpl.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ import dev.restate.sdk.types.StateKey
1515
class ListObjectImpl : ListObject {
1616
companion object {
1717
private val LIST_KEY: StateKey<List<String>> =
18-
stateKey<List<String>>(
18+
stateKey(
1919
"list",
2020
)
2121
}

test-services/src/main/kotlin/dev/restate/sdk/testservices/ProxyImpl.kt

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -35,10 +35,11 @@ class ProxyImpl : Proxy {
3535
.await()
3636
}
3737

38-
override suspend fun oneWayCall(context: Context, request: ProxyRequest) {
39-
context.send(
40-
SendRequest.of(request.toTarget(), Serde.RAW, request.message)
41-
.delay((request.delayMillis?.milliseconds ?: Duration.ZERO).toJavaDuration()))
38+
override suspend fun oneWayCall(context: Context, request: ProxyRequest): Unit {
39+
val ignored =
40+
context.send(
41+
SendRequest.of(request.toTarget(), Serde.RAW, request.message)
42+
.delay((request.delayMillis?.milliseconds ?: Duration.ZERO).toJavaDuration()))
4243
}
4344

4445
override suspend fun manyCalls(context: Context, requests: List<ManyCallRequest>) {

0 commit comments

Comments
 (0)