Skip to content

Commit 74cf215

Browse files
committed
rename variable for clarify
1 parent fcd0e10 commit 74cf215

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

src/kafka-consumer.cc

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1078,14 +1078,15 @@ NAN_METHOD(KafkaConsumer::NodeConsumeLoop) {
10781078
} else {
10791079
timeout_ms = static_cast<int>(maybeTimeout.FromJust());
10801080
}
1081-
int retry_read_ms;
1081+
1082+
int timeout_sleep_delay_ms;
10821083
Nan::Maybe<uint32_t> maybeSleep =
10831084
Nan::To<uint32_t>(info[1].As<v8::Number>());
10841085

10851086
if (maybeSleep.IsNothing()) {
1086-
retry_read_ms = 500;
1087+
timeout_sleep_delay_ms = 500;
10871088
} else {
1088-
retry_read_ms = static_cast<int>(maybeSleep.FromJust());
1089+
timeout_sleep_delay_ms = static_cast<int>(maybeSleep.FromJust());
10891090
}
10901091

10911092
KafkaConsumer* consumer = ObjectWrap::Unwrap<KafkaConsumer>(info.This());
@@ -1102,7 +1103,7 @@ NAN_METHOD(KafkaConsumer::NodeConsumeLoop) {
11021103

11031104
Nan::Callback *callback = new Nan::Callback(cb);
11041105

1105-
consumer->m_consume_loop = new Workers::KafkaConsumerConsumeLoop(callback, consumer, timeout_ms, retry_read_ms);
1106+
consumer->m_consume_loop = new Workers::KafkaConsumerConsumeLoop(callback, consumer, timeout_ms, timeout_sleep_delay_ms);
11061107

11071108
info.GetReturnValue().Set(Nan::Null());
11081109
}

0 commit comments

Comments
 (0)