def METHOD_NAME(self, write_intent: WriteIntent, full_read_size: int = 1) -> bytes:
    buffer_stream = write_intent.outbound_source.open()  # noqa
    read_data = buffer_stream.read(full_read_size)
    empty_data = buffer_stream.read(full_read_size)
    self.assertEqual(0, len(empty_data))
    buffer_stream.close()
    return read_data