Skip to content

Commit 7bb0583

Browse files
committed
fix: reorder import statements for consistency in commit offset request and handle server message files
Signed-off-by: Vladislav Polyakov <[email protected]>
1 parent 3ec4772 commit 7bb0583

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

packages/topic/src/reader/_commit_offset_request.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
import { create } from "@bufbuild/protobuf";
2-
import { type StreamReadMessage_FromClient, StreamReadMessage_FromClientSchema, type StreamReadMessage_CommitOffsetRequest_PartitionCommitOffset } from "@ydbjs/api/topic";
2+
import { type StreamReadMessage_CommitOffsetRequest_PartitionCommitOffset, type StreamReadMessage_FromClient, StreamReadMessage_FromClientSchema } from "@ydbjs/api/topic";
33
import type { AsyncPriorityQueue } from "../queue.js";
44

55
export let _send_commit_offset_request = function send_commit_offset_request(ctx: {

packages/topic/src/reader/_handle_server_message.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ import { loggers } from "@ydbjs/debug";
66
import { TopicPartitionSession } from "../partition-session.js";
77
import { _send_start_partition_session_response } from "./_start_partition_session_response.js";
88
import { _send_stop_partition_session_response } from "./_stop_partition_session_response.js";
9-
import type { TopicReaderOptions, TopicCommitPromise } from "./types.js";
9+
import type { TopicCommitPromise, TopicReaderOptions } from "./types.js";
1010

1111
let dbg = loggers.topic.extend('reader')
1212

0 commit comments

Comments
 (0)