|
|
@ -254,7 +254,7 @@ cdef class ByteBuffer: |
|
|
|
if self.c_byte_buffer != NULL: |
|
|
|
if self.c_byte_buffer != NULL: |
|
|
|
with nogil: |
|
|
|
with nogil: |
|
|
|
grpc_byte_buffer_reader_init(&reader, self.c_byte_buffer) |
|
|
|
grpc_byte_buffer_reader_init(&reader, self.c_byte_buffer) |
|
|
|
result = b"" |
|
|
|
result = bytearray() |
|
|
|
with nogil: |
|
|
|
with nogil: |
|
|
|
while grpc_byte_buffer_reader_next(&reader, &data_slice): |
|
|
|
while grpc_byte_buffer_reader_next(&reader, &data_slice): |
|
|
|
data_slice_pointer = gpr_slice_start_ptr(data_slice) |
|
|
|
data_slice_pointer = gpr_slice_start_ptr(data_slice) |
|
|
@ -263,7 +263,7 @@ cdef class ByteBuffer: |
|
|
|
result += (<char *>data_slice_pointer)[:data_slice_length] |
|
|
|
result += (<char *>data_slice_pointer)[:data_slice_length] |
|
|
|
with nogil: |
|
|
|
with nogil: |
|
|
|
grpc_byte_buffer_reader_destroy(&reader) |
|
|
|
grpc_byte_buffer_reader_destroy(&reader) |
|
|
|
return result |
|
|
|
return bytes(result) |
|
|
|
else: |
|
|
|
else: |
|
|
|
return None |
|
|
|
return None |
|
|
|
|
|
|
|
|
|
|
|