|
8 | 8 | import java.util.concurrent.Executors; |
9 | 9 | import java.util.function.Consumer; |
10 | 10 |
|
| 11 | +import javax.annotation.Nonnull; |
| 12 | + |
11 | 13 | import org.slf4j.Logger; |
12 | 14 | import org.slf4j.LoggerFactory; |
13 | 15 |
|
|
16 | 18 | import tech.ydb.proto.topic.YdbTopic; |
17 | 19 | import tech.ydb.topic.TopicRpc; |
18 | 20 | import tech.ydb.topic.description.CodecRegistry; |
| 21 | +import tech.ydb.topic.impl.UnModifiableRegistry; |
19 | 22 | import tech.ydb.topic.read.AsyncReader; |
20 | 23 | import tech.ydb.topic.read.PartitionOffsets; |
21 | 24 | import tech.ydb.topic.read.PartitionSession; |
@@ -46,10 +49,17 @@ public class AsyncReaderImpl extends ReaderImpl implements AsyncReader { |
46 | 49 | private final ExecutorService defaultHandlerExecutorService; |
47 | 50 | private final ReadEventHandler eventHandler; |
48 | 51 |
|
| 52 | + @Deprecated |
| 53 | + public AsyncReaderImpl(TopicRpc topicRpc, |
| 54 | + ReaderSettings settings, |
| 55 | + ReadEventHandlersSettings handlersSettings) { |
| 56 | + this(topicRpc, settings, handlersSettings, UnModifiableRegistry.getInstance()); |
| 57 | + |
| 58 | + } |
49 | 59 | public AsyncReaderImpl(TopicRpc topicRpc, |
50 | 60 | ReaderSettings settings, |
51 | 61 | ReadEventHandlersSettings handlersSettings, |
52 | | - CodecRegistry codecRegistry) { |
| 62 | + @Nonnull CodecRegistry codecRegistry) { |
53 | 63 | super(topicRpc, settings, codecRegistry); |
54 | 64 | this.eventHandler = handlersSettings.getEventHandler(); |
55 | 65 |
|
|
0 commit comments