Clean up temporary hold over from previous PR
This commit is contained in:
parent
b214f88f75
commit
a099b9c65d
|
@ -25,16 +25,6 @@ def encode_msg_with_length(msg_bytes: bytes) -> bytes:
|
||||||
return len_prefix + msg_bytes
|
return len_prefix + msg_bytes
|
||||||
|
|
||||||
|
|
||||||
# NOTE: temporary for this PR
|
|
||||||
encode = encode_msg_with_length
|
|
||||||
|
|
||||||
|
|
||||||
# NOTE: temporary for this PR
|
|
||||||
async def read_next_message(reader: Reader) -> bytes:
|
|
||||||
length = await read_length(reader)
|
|
||||||
return await reader.read(length)
|
|
||||||
|
|
||||||
|
|
||||||
class MsgIOWriter(WriteCloser):
|
class MsgIOWriter(WriteCloser):
|
||||||
write_closer: WriteCloser
|
write_closer: WriteCloser
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue
Block a user