Skip to content

Commit da80e66

Browse files
committed
restore subscriber
1 parent 0af0ad6 commit da80e66

File tree

1 file changed

+1
-11
lines changed

1 file changed

+1
-11
lines changed

src/main/java/software/amazon/encryption/s3/internal/CipherSubscriber.java

Lines changed: 1 addition & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -47,17 +47,7 @@ public class CipherSubscriber implements Subscriber<ByteBuffer> {
4747

4848
@Override
4949
public void onSubscribe(Subscription s) {
50-
wrappedSubscriber.onSubscribe(new Subscription() {
51-
@Override
52-
public void request(long n) {
53-
s.request(n);
54-
}
55-
56-
@Override
57-
public void cancel() {
58-
s.cancel();
59-
}
60-
});
50+
wrappedSubscriber.onSubscribe(s);
6151
}
6252

6353
@Override

0 commit comments

Comments
 (0)