Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Ian UI d2 1728 identity buckets oom #492

Open
wants to merge 14 commits into
base: main
Choose a base branch
from
Prev Previous commit
Next Next commit
rename interface
  • Loading branch information
Ian-Nara committed Apr 17, 2024
commit 4f0bbf7492138a5cc9c9f5c1be734df4f4e59107
Original file line number Diff line number Diff line change
@@ -8,8 +8,8 @@
import io.vertx.core.streams.ReadStream;
import io.vertx.core.streams.WriteStream;

public interface IModifiedBucketEncryptStream extends ReadStream<Buffer>, WriteStream<Buffer> {
IModifiedBucketEncryptStream exceptionHandler(Handler<Throwable> handler);
public interface IModifiedBucketReadWriteStream extends ReadStream<Buffer>, WriteStream<Buffer> {
IModifiedBucketReadWriteStream exceptionHandler(Handler<Throwable> handler);

Future<Void> write(Buffer buffer);

Original file line number Diff line number Diff line change
@@ -15,7 +15,7 @@
import java.util.Arrays;


public class ModifiedBucketEncodeStream implements IModifiedBucketEncryptStream {
public class ModifiedBucketEncodeStream implements IModifiedBucketReadWriteStream {
private static final Logger LOGGER = LoggerFactory.getLogger(ModifiedBucketEncodeStream.class);

private final Context context;
@@ -39,7 +39,7 @@ public ModifiedBucketEncodeStream(Context context) {
}

@Override
public synchronized IModifiedBucketEncryptStream exceptionHandler(Handler<Throwable> handler) {
public synchronized IModifiedBucketReadWriteStream exceptionHandler(Handler<Throwable> handler) {
this.exceptionHandler = handler;
return this;
}
Original file line number Diff line number Diff line change
@@ -22,7 +22,7 @@
import java.security.NoSuchAlgorithmException;


public class ModifiedBucketEncryptStream implements IModifiedBucketEncryptStream {
public class ModifiedBucketEncryptStream implements IModifiedBucketReadWriteStream {
private static final Logger LOGGER = LoggerFactory.getLogger(ModifiedBucketEncryptStream.class);

private final Context context;
@@ -60,7 +60,7 @@ public ModifiedBucketEncryptStream(Context context, byte[] encryptionKey, byte[]
}

@Override
public synchronized IModifiedBucketEncryptStream exceptionHandler(Handler<Throwable> handler) {
public synchronized IModifiedBucketReadWriteStream exceptionHandler(Handler<Throwable> handler) {
this.exceptionHandler = handler;
return this;
}
Loading