swift-server/RediStack
1
0
Fork 0
mirror of https://github.com/swift-server/RediStack.git synced 2026-06-02 07:37:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix decoding bug with arrays and remove unnecessary extensions

Browse Source
This commit is contained in:
Nathan Harris
2018-12-18 22:55:40 -08:00
parent 7b1d2b46c5
commit 15859bcf19
1 changed files with 1 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Sources/NIORedis/Coders/RedisDataDecoder.swift
+1 -25
View File
@@ -46,7 +46,7 @@ extension RedisDataDecoder {
}
func _parse(at position: inout Int, from buffer: inout ByteBuffer) throws -> _RedisDataDecodingState {
guard let token = buffer.copyByte(at: position) else { return .notYetParsed }
guard let token = buffer.copyBytes(at: position, length: 1)?.first else { return .notYetParsed }
position += 1
@@ -188,19 +188,6 @@ extension RedisDataDecoder {
}
private extension ByteBuffer {
/// Copies the `ByteBuffer` from the current `readerIndex`.
///
/// buffer.copyBytes(count: 5)
/// // Optional(5 bytes)
///
/// - Parameters:
/// - count: The number of bytes to copy
/// - skipping: The amount of bytes to skip, defaulting to `0`.
func copyBytes(count: Int, skipping: Int = 0) -> [UInt8]? {
guard readableBytes >= count + skipping else { return nil }
return getBytes(at: readerIndex + skipping, length: count)
}
/// Copies bytes from the `ByteBuffer` from at the provided position, up to the length desired.
///
/// buffer.copyBytes(at: 3, length: 2)
@@ -213,15 +200,4 @@ private extension ByteBuffer {
guard readableBytes >= offset + length else { return nil }
return getBytes(at: offset + readerIndex, length: length)
}
/// Copies the first byte from the `ByteBuffer` at the desired position.
///
/// buffer.copyByte(at: 3)
/// // Optional(1 byte), assuming buffer contains 3 or more bytes
///
/// - Parameter at: The position offset of the byte to be copied from the buffer.
func copyByte(at position: Int) -> UInt8? {
guard readableBytes >= 1 else { return nil }
return getBytes(at: position, length: 1)?.first
}
}