|
18 | 18 | import com.fasterxml.jackson.databind.ObjectMapper;
|
19 | 19 | import com.google.protobuf.Any;
|
20 | 20 | import com.google.protobuf.ByteString;
|
21 |
| -import io.dapr.client.domain.*; |
| 21 | +import io.dapr.client.domain.BulkPublishEntry; |
| 22 | +import io.dapr.client.domain.BulkPublishRequest; |
| 23 | +import io.dapr.client.domain.BulkPublishResponse; |
| 24 | +import io.dapr.client.domain.CloudEvent; |
| 25 | +import io.dapr.client.domain.DeleteJobRequest; |
| 26 | +import io.dapr.client.domain.GetJobRequest; |
| 27 | +import io.dapr.client.domain.GetJobResponse; |
| 28 | +import io.dapr.client.domain.JobSchedule; |
| 29 | +import io.dapr.client.domain.QueryStateItem; |
| 30 | +import io.dapr.client.domain.QueryStateRequest; |
| 31 | +import io.dapr.client.domain.QueryStateResponse; |
| 32 | +import io.dapr.client.domain.ScheduleJobRequest; |
| 33 | +import io.dapr.client.domain.UnlockResponseStatus; |
22 | 34 | import io.dapr.client.domain.query.Query;
|
23 | 35 | import io.dapr.serializer.DaprObjectSerializer;
|
24 | 36 | import io.dapr.serializer.DefaultObjectSerializer;
|
25 | 37 | import io.dapr.utils.TypeRef;
|
26 | 38 | import io.dapr.v1.DaprAppCallbackProtos;
|
27 | 39 | import io.dapr.v1.DaprGrpc;
|
28 | 40 | import io.dapr.v1.DaprProtos;
|
29 |
| -import io.grpc.ManagedChannel; |
30 | 41 | import io.grpc.Status;
|
31 | 42 | import io.grpc.StatusRuntimeException;
|
32 | 43 | import io.grpc.stub.StreamObserver;
|
|
60 | 71 | import java.util.concurrent.atomic.AtomicInteger;
|
61 | 72 |
|
62 | 73 | import static io.dapr.utils.TestUtils.assertThrowsDaprException;
|
63 |
| -import static org.junit.jupiter.api.Assertions.*; |
| 74 | +import static org.junit.jupiter.api.Assertions.assertDoesNotThrow; |
| 75 | +import static org.junit.jupiter.api.Assertions.assertEquals; |
| 76 | +import static org.junit.jupiter.api.Assertions.assertFalse; |
| 77 | +import static org.junit.jupiter.api.Assertions.assertNotNull; |
| 78 | +import static org.junit.jupiter.api.Assertions.assertNull; |
| 79 | +import static org.junit.jupiter.api.Assertions.assertThrows; |
64 | 80 | import static org.mockito.ArgumentMatchers.any;
|
65 |
| -import static org.mockito.Mockito.*; |
| 81 | +import static org.mockito.Mockito.doAnswer; |
| 82 | +import static org.mockito.Mockito.doNothing; |
| 83 | +import static org.mockito.Mockito.mock; |
66 | 84 | import static org.mockito.Mockito.times;
|
| 85 | +import static org.mockito.Mockito.verify; |
| 86 | +import static org.mockito.Mockito.verifyNoMoreInteractions; |
| 87 | +import static org.mockito.Mockito.when; |
67 | 88 |
|
68 | 89 | public class DaprPreviewClientGrpcTest {
|
69 | 90 |
|
|
0 commit comments