Skip to content

Commit c16de4d

Browse files
committed
Address comments.
1 parent def7411 commit c16de4d

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

src/core.jl

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -138,10 +138,9 @@ end
138138

139139
function check_channel_name(channelptr::Ptr{UInt8}, opts::SubscriptionOptions)
140140
i = 1
141-
while (byte = unsafe_load(channelptr)) != 0x00
142-
byte == UInt8(opts.channel[i]) || error("Mismatch between received channel name and subscription channel name")
141+
while (byte = unsafe_load(channelptr, i)) != 0x00
142+
byte == codeunit(opts.channel, i) || error("Mismatch between received channel name and subscription channel name")
143143
i += 1
144-
channelptr += 1
145144
end
146145
end
147146

0 commit comments

Comments
 (0)