Skip to content

Commit

Permalink
Rename proto java package
Browse files Browse the repository at this point in the history
  • Loading branch information
@w1am
w1am committed Dec 16, 2024
1 parent 9184c3e commit 88f6db5
Show file tree
Hide file tree
Showing 56 changed files with 116 additions and 116 deletions.
4 changes: 2 additions & 2 deletions db-client-java/src/main/java/io/kurrent/dbclient/AbortProjection.java
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.projections.Projectionmanagement;
import com.eventstore.dbclient.proto.projections.ProjectionsGrpc;
import io.kurrent.dbclient.proto.projections.Projectionmanagement;
import io.kurrent.dbclient.proto.projections.ProjectionsGrpc;

import java.util.concurrent.CompletableFuture;

Expand Down
4 changes: 2 additions & 2 deletions db-client-java/src/main/java/io/kurrent/dbclient/AbstractCreatePersistentSubscription.java
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.persistentsubscriptions.Persistent;
import com.eventstore.dbclient.proto.persistentsubscriptions.PersistentSubscriptionsGrpc;
import io.kurrent.dbclient.proto.persistentsubscriptions.Persistent;
import io.kurrent.dbclient.proto.persistentsubscriptions.PersistentSubscriptionsGrpc;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

Expand Down
4 changes: 2 additions & 2 deletions db-client-java/src/main/java/io/kurrent/dbclient/AbstractDeletePersistentSubscription.java
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.persistentsubscriptions.Persistent;
import com.eventstore.dbclient.proto.persistentsubscriptions.PersistentSubscriptionsGrpc;
import io.kurrent.dbclient.proto.persistentsubscriptions.Persistent;
import io.kurrent.dbclient.proto.persistentsubscriptions.PersistentSubscriptionsGrpc;

import java.util.concurrent.CompletableFuture;

Expand Down
6 changes: 3 additions & 3 deletions db-client-java/src/main/java/io/kurrent/dbclient/AbstractRead.java
View file
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.shared.Shared;
import com.eventstore.dbclient.proto.streams.StreamsGrpc;
import com.eventstore.dbclient.proto.streams.StreamsOuterClass;
import io.kurrent.dbclient.proto.shared.Shared;
import io.kurrent.dbclient.proto.streams.StreamsGrpc;
import io.kurrent.dbclient.proto.streams.StreamsOuterClass;
import io.grpc.Metadata;
import io.grpc.StatusRuntimeException;
import io.grpc.stub.ClientCallStreamObserver;
Expand Down
6 changes: 3 additions & 3 deletions db-client-java/src/main/java/io/kurrent/dbclient/AbstractRegularSubscription.java
View file
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.shared.Shared;
import com.eventstore.dbclient.proto.streams.StreamsGrpc;
import com.eventstore.dbclient.proto.streams.StreamsOuterClass;
import io.kurrent.dbclient.proto.shared.Shared;
import io.kurrent.dbclient.proto.streams.StreamsGrpc;
import io.kurrent.dbclient.proto.streams.StreamsOuterClass;
import io.grpc.Metadata;
import io.grpc.Status;
import io.grpc.StatusRuntimeException;
Expand Down
6 changes: 3 additions & 3 deletions ...lient-java/src/main/java/io/kurrent/dbclient/AbstractSubscribePersistentSubscription.java
View file
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.persistentsubscriptions.Persistent;
import com.eventstore.dbclient.proto.persistentsubscriptions.PersistentSubscriptionsGrpc;
import com.eventstore.dbclient.proto.shared.Shared;
import io.kurrent.dbclient.proto.persistentsubscriptions.Persistent;
import io.kurrent.dbclient.proto.persistentsubscriptions.PersistentSubscriptionsGrpc;
import io.kurrent.dbclient.proto.shared.Shared;
import io.grpc.Metadata;
import io.grpc.Status;
import io.grpc.StatusRuntimeException;
Expand Down
4 changes: 2 additions & 2 deletions db-client-java/src/main/java/io/kurrent/dbclient/AbstractUpdatePersistentSubscription.java
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.persistentsubscriptions.Persistent;
import com.eventstore.dbclient.proto.persistentsubscriptions.PersistentSubscriptionsGrpc;
import io.kurrent.dbclient.proto.persistentsubscriptions.Persistent;
import io.kurrent.dbclient.proto.persistentsubscriptions.PersistentSubscriptionsGrpc;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

Expand Down
6 changes: 3 additions & 3 deletions db-client-java/src/main/java/io/kurrent/dbclient/AppendToStream.java
View file
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.shared.Shared;
import com.eventstore.dbclient.proto.streams.StreamsGrpc;
import com.eventstore.dbclient.proto.streams.StreamsOuterClass;
import io.kurrent.dbclient.proto.shared.Shared;
import io.kurrent.dbclient.proto.streams.StreamsGrpc;
import io.kurrent.dbclient.proto.streams.StreamsOuterClass;
import com.google.protobuf.ByteString;
import io.grpc.ManagedChannel;
import io.grpc.Metadata;
Expand Down
4 changes: 2 additions & 2 deletions db-client-java/src/main/java/io/kurrent/dbclient/ClusterInfo.java
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.gossip.GossipOuterClass;
import com.eventstore.dbclient.proto.shared.Shared;
import io.kurrent.dbclient.proto.gossip.GossipOuterClass;
import io.kurrent.dbclient.proto.shared.Shared;

import java.net.InetSocketAddress;
import java.util.ArrayList;
Expand Down
4 changes: 2 additions & 2 deletions db-client-java/src/main/java/io/kurrent/dbclient/CreatePersistentSubscriptionToAll.java
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.persistentsubscriptions.Persistent;
import com.eventstore.dbclient.proto.shared.Shared;
import io.kurrent.dbclient.proto.persistentsubscriptions.Persistent;
import io.kurrent.dbclient.proto.shared.Shared;

class CreatePersistentSubscriptionToAll extends AbstractCreatePersistentSubscription<Position, PersistentSubscriptionToAllSettings> {
private final CreatePersistentSubscriptionToAllOptions options;
Expand Down
4 changes: 2 additions & 2 deletions db-client-java/src/main/java/io/kurrent/dbclient/CreatePersistentSubscriptionToStream.java
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.persistentsubscriptions.Persistent;
import com.eventstore.dbclient.proto.shared.Shared;
import io.kurrent.dbclient.proto.persistentsubscriptions.Persistent;
import io.kurrent.dbclient.proto.shared.Shared;
import com.google.protobuf.ByteString;

class CreatePersistentSubscriptionToStream extends AbstractCreatePersistentSubscription<Long, PersistentSubscriptionToStreamSettings> {
Expand Down
4 changes: 2 additions & 2 deletions db-client-java/src/main/java/io/kurrent/dbclient/CreateProjection.java
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.projections.Projectionmanagement;
import com.eventstore.dbclient.proto.projections.ProjectionsGrpc;
import io.kurrent.dbclient.proto.projections.Projectionmanagement;
import io.kurrent.dbclient.proto.projections.ProjectionsGrpc;

import java.util.concurrent.CompletableFuture;

Expand Down
4 changes: 2 additions & 2 deletions db-client-java/src/main/java/io/kurrent/dbclient/DeletePersistentSubscriptionToAll.java
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.persistentsubscriptions.Persistent;
import com.eventstore.dbclient.proto.shared.Shared;
import io.kurrent.dbclient.proto.persistentsubscriptions.Persistent;
import io.kurrent.dbclient.proto.shared.Shared;

class DeletePersistentSubscriptionToAll extends AbstractDeletePersistentSubscription {
public DeletePersistentSubscriptionToAll(GrpcClient client, String group,
Expand Down
4 changes: 2 additions & 2 deletions db-client-java/src/main/java/io/kurrent/dbclient/DeletePersistentSubscriptionToStream.java
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.persistentsubscriptions.Persistent;
import com.eventstore.dbclient.proto.shared.Shared;
import io.kurrent.dbclient.proto.persistentsubscriptions.Persistent;
import io.kurrent.dbclient.proto.shared.Shared;
import com.google.protobuf.ByteString;

class DeletePersistentSubscriptionToStream extends AbstractDeletePersistentSubscription {
Expand Down
4 changes: 2 additions & 2 deletions db-client-java/src/main/java/io/kurrent/dbclient/DeleteProjection.java
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.projections.Projectionmanagement;
import com.eventstore.dbclient.proto.projections.ProjectionsGrpc;
import io.kurrent.dbclient.proto.projections.Projectionmanagement;
import io.kurrent.dbclient.proto.projections.ProjectionsGrpc;

import java.util.concurrent.CompletableFuture;

Expand Down
6 changes: 3 additions & 3 deletions db-client-java/src/main/java/io/kurrent/dbclient/DeleteStream.java
View file
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.shared.Shared;
import com.eventstore.dbclient.proto.streams.StreamsGrpc;
import com.eventstore.dbclient.proto.streams.StreamsOuterClass;
import io.kurrent.dbclient.proto.shared.Shared;
import io.kurrent.dbclient.proto.streams.StreamsGrpc;
import io.kurrent.dbclient.proto.streams.StreamsOuterClass;
import com.google.protobuf.ByteString;
import io.grpc.Metadata;

Expand Down
4 changes: 2 additions & 2 deletions db-client-java/src/main/java/io/kurrent/dbclient/DisableProjection.java
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.projections.Projectionmanagement;
import com.eventstore.dbclient.proto.projections.ProjectionsGrpc;
import io.kurrent.dbclient.proto.projections.Projectionmanagement;
import io.kurrent.dbclient.proto.projections.ProjectionsGrpc;

import java.util.concurrent.CompletableFuture;

Expand Down
4 changes: 2 additions & 2 deletions db-client-java/src/main/java/io/kurrent/dbclient/EnableProjection.java
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.projections.Projectionmanagement;
import com.eventstore.dbclient.proto.projections.ProjectionsGrpc;
import io.kurrent.dbclient.proto.projections.Projectionmanagement;
import io.kurrent.dbclient.proto.projections.ProjectionsGrpc;

import java.util.concurrent.CompletableFuture;

Expand Down
4 changes: 2 additions & 2 deletions db-client-java/src/main/java/io/kurrent/dbclient/ExpectedRevision.java
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.shared.Shared;
import com.eventstore.dbclient.proto.streams.StreamsOuterClass;
import io.kurrent.dbclient.proto.shared.Shared;
import io.kurrent.dbclient.proto.streams.StreamsOuterClass;

import java.util.Objects;

Expand Down
6 changes: 3 additions & 3 deletions db-client-java/src/main/java/io/kurrent/dbclient/GetPersistentSubscriptionInfo.java
View file
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.persistentsubscriptions.Persistent;
import com.eventstore.dbclient.proto.persistentsubscriptions.PersistentSubscriptionsGrpc;
import com.eventstore.dbclient.proto.shared.Shared;
import io.kurrent.dbclient.proto.persistentsubscriptions.Persistent;
import io.kurrent.dbclient.proto.persistentsubscriptions.PersistentSubscriptionsGrpc;
import io.kurrent.dbclient.proto.shared.Shared;
import com.fasterxml.jackson.databind.JsonNode;
import com.google.protobuf.ByteString;
import io.grpc.Status;
Expand Down
4 changes: 2 additions & 2 deletions db-client-java/src/main/java/io/kurrent/dbclient/GetProjectionResult.java
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.projections.Projectionmanagement;
import com.eventstore.dbclient.proto.projections.ProjectionsGrpc;
import io.kurrent.dbclient.proto.projections.Projectionmanagement;
import io.kurrent.dbclient.proto.projections.ProjectionsGrpc;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.JavaType;
import com.fasterxml.jackson.databind.json.JsonMapper;
Expand Down
4 changes: 2 additions & 2 deletions db-client-java/src/main/java/io/kurrent/dbclient/GetProjectionState.java
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.projections.Projectionmanagement;
import com.eventstore.dbclient.proto.projections.ProjectionsGrpc;
import io.kurrent.dbclient.proto.projections.Projectionmanagement;
import io.kurrent.dbclient.proto.projections.ProjectionsGrpc;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.JavaType;
import com.fasterxml.jackson.databind.json.JsonMapper;
Expand Down
4 changes: 2 additions & 2 deletions db-client-java/src/main/java/io/kurrent/dbclient/GetProjectionStatistics.java
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.projections.Projectionmanagement;
import com.eventstore.dbclient.proto.projections.ProjectionsGrpc;
import io.kurrent.dbclient.proto.projections.Projectionmanagement;
import io.kurrent.dbclient.proto.projections.ProjectionsGrpc;

import java.util.concurrent.CompletableFuture;

Expand Down
4 changes: 2 additions & 2 deletions db-client-java/src/main/java/io/kurrent/dbclient/GetProjectionStatus.java
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.projections.Projectionmanagement;
import com.eventstore.dbclient.proto.projections.ProjectionsGrpc;
import io.kurrent.dbclient.proto.projections.Projectionmanagement;
import io.kurrent.dbclient.proto.projections.ProjectionsGrpc;

import java.util.concurrent.CompletableFuture;

Expand Down
6 changes: 3 additions & 3 deletions db-client-java/src/main/java/io/kurrent/dbclient/GossipClient.java
View file
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.gossip.GossipGrpc;
import com.eventstore.dbclient.proto.gossip.GossipOuterClass;
import com.eventstore.dbclient.proto.shared.Shared;
import io.kurrent.dbclient.proto.gossip.GossipGrpc;
import io.kurrent.dbclient.proto.gossip.GossipOuterClass;
import io.kurrent.dbclient.proto.shared.Shared;
import io.grpc.ManagedChannel;
import io.grpc.stub.ClientCallStreamObserver;
import io.grpc.stub.ClientResponseObserver;
Expand Down
4 changes: 2 additions & 2 deletions db-client-java/src/main/java/io/kurrent/dbclient/GrpcUtils.java
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.shared.Shared;
import com.eventstore.dbclient.proto.streams.StreamsOuterClass;
import io.kurrent.dbclient.proto.shared.Shared;
import io.kurrent.dbclient.proto.streams.StreamsOuterClass;
import com.google.protobuf.ByteString;
import io.grpc.Metadata;
import io.grpc.Status;
Expand Down
2 changes: 1 addition & 1 deletion db-client-java/src/main/java/io/kurrent/dbclient/HttpUtils.java
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.persistentsubscriptions.Persistent;
import io.kurrent.dbclient.proto.persistentsubscriptions.Persistent;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;

Expand Down
6 changes: 3 additions & 3 deletions db-client-java/src/main/java/io/kurrent/dbclient/ListPersistentSubscriptions.java
View file
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.persistentsubscriptions.PersistentSubscriptionsGrpc;
import com.eventstore.dbclient.proto.shared.Shared;
import io.kurrent.dbclient.proto.persistentsubscriptions.PersistentSubscriptionsGrpc;
import io.kurrent.dbclient.proto.shared.Shared;
import com.fasterxml.jackson.databind.JsonNode;
import com.eventstore.dbclient.proto.persistentsubscriptions.Persistent;
import io.kurrent.dbclient.proto.persistentsubscriptions.Persistent;
import com.google.protobuf.ByteString;

import java.io.IOException;
Expand Down
6 changes: 3 additions & 3 deletions db-client-java/src/main/java/io/kurrent/dbclient/ListProjections.java
View file
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.projections.Projectionmanagement;
import com.eventstore.dbclient.proto.projections.ProjectionsGrpc;
import com.eventstore.dbclient.proto.shared.Shared;
import io.kurrent.dbclient.proto.projections.Projectionmanagement;
import io.kurrent.dbclient.proto.projections.ProjectionsGrpc;
import io.kurrent.dbclient.proto.shared.Shared;
import io.grpc.stub.StreamObserver;

import java.util.ArrayList;
Expand Down
4 changes: 2 additions & 2 deletions db-client-java/src/main/java/io/kurrent/dbclient/PersistentSubscription.java
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.persistentsubscriptions.Persistent;
import com.eventstore.dbclient.proto.shared.Shared;
import io.kurrent.dbclient.proto.persistentsubscriptions.Persistent;
import io.kurrent.dbclient.proto.shared.Shared;
import com.google.protobuf.ByteString;
import io.grpc.stub.ClientCallStreamObserver;

Expand Down
2 changes: 1 addition & 1 deletion db-client-java/src/main/java/io/kurrent/dbclient/ProjectionDetails.java
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.projections.Projectionmanagement;
import io.kurrent.dbclient.proto.projections.Projectionmanagement;

/**
* Provides the details for a projection.
Expand Down
4 changes: 2 additions & 2 deletions db-client-java/src/main/java/io/kurrent/dbclient/ReadAll.java
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.shared.Shared;
import com.eventstore.dbclient.proto.streams.StreamsOuterClass;
import io.kurrent.dbclient.proto.shared.Shared;
import io.kurrent.dbclient.proto.streams.StreamsOuterClass;

class ReadAll extends AbstractRead {
private final ReadAllOptions options;
Expand Down
2 changes: 1 addition & 1 deletion db-client-java/src/main/java/io/kurrent/dbclient/ReadMessage.java
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.streams.StreamsOuterClass;
import io.kurrent.dbclient.proto.streams.StreamsOuterClass;

/**
* Received when performing a regular read operation (not a subscription).
Expand Down
4 changes: 2 additions & 2 deletions db-client-java/src/main/java/io/kurrent/dbclient/ReadStream.java
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.shared.Shared;
import com.eventstore.dbclient.proto.streams.StreamsOuterClass;
import io.kurrent.dbclient.proto.shared.Shared;
import io.kurrent.dbclient.proto.streams.StreamsOuterClass;

/**
* TODO - Implement a better way to handle very long stream to not end
Expand Down
6 changes: 3 additions & 3 deletions db-client-java/src/main/java/io/kurrent/dbclient/RecordedEvent.java
View file
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.persistentsubscriptions.Persistent;
import com.eventstore.dbclient.proto.shared.Shared;
import com.eventstore.dbclient.proto.streams.StreamsOuterClass;
import io.kurrent.dbclient.proto.persistentsubscriptions.Persistent;
import io.kurrent.dbclient.proto.shared.Shared;
import io.kurrent.dbclient.proto.streams.StreamsOuterClass;
import com.fasterxml.jackson.databind.json.JsonMapper;

import javax.validation.constraints.NotNull;
Expand Down
6 changes: 3 additions & 3 deletions db-client-java/src/main/java/io/kurrent/dbclient/ReplayParkedMessages.java
View file
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.persistentsubscriptions.Persistent;
import com.eventstore.dbclient.proto.persistentsubscriptions.PersistentSubscriptionsGrpc;
import com.eventstore.dbclient.proto.shared.Shared;
import io.kurrent.dbclient.proto.persistentsubscriptions.Persistent;
import io.kurrent.dbclient.proto.persistentsubscriptions.PersistentSubscriptionsGrpc;
import io.kurrent.dbclient.proto.shared.Shared;
import com.google.protobuf.ByteString;

import java.io.IOException;
Expand Down
4 changes: 2 additions & 2 deletions db-client-java/src/main/java/io/kurrent/dbclient/ResetProjection.java
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.projections.Projectionmanagement;
import com.eventstore.dbclient.proto.projections.ProjectionsGrpc;
import io.kurrent.dbclient.proto.projections.Projectionmanagement;
import io.kurrent.dbclient.proto.projections.ProjectionsGrpc;

import java.util.concurrent.CompletableFuture;

Expand Down
4 changes: 2 additions & 2 deletions db-client-java/src/main/java/io/kurrent/dbclient/ResolvedEvent.java
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.kurrent.dbclient;

import com.eventstore.dbclient.proto.persistentsubscriptions.Persistent;
import com.eventstore.dbclient.proto.streams.StreamsOuterClass;
import io.kurrent.dbclient.proto.persistentsubscriptions.Persistent;
import io.kurrent.dbclient.proto.streams.StreamsOuterClass;

import java.util.Objects;
import java.util.Optional;
Expand Down
Loading

0 comments on commit 88f6db5

Please sign in to comment.