async def METHOD_NAME(encoder, event_data):
    # get content as bytes
    content = bytearray()
    for d in event_data.body:
        content += d
    content_bytes = bytes(content)
    message_content = MessageContent({"content": content_bytes, "content_type": event_data.content_type})
    decoded_content = await encoder.decode(message_content)
    print("Decoded content is: ", decoded_content)
    return decoded_content