streaming_data_types/utils.py
def check_schema_identifier(buffer, expected_identifer: bytes):
    """
    Check the schema code embedded in the buffer matches an expected identifier

    :param buffer: The raw buffer of the FlatBuffers message
    :param expected_identifer: The expected flatbuffer identifier
    """
    if get_schema(buffer) != expected_identifer.decode():
        raise WrongSchemaException(
            f"Incorrect schema: expected {expected_identifer} but got {get_schema(buffer)}"
        )

    Check the schema code embedded in the buffer matches an expected identifier

    :param buffer: The raw buffer of the FlatBuffers message
    :param expected_identifer: The expected flatbuffer identifier
    
Check the schema code embedded in the buffer matches an expected identifier
Check the schema code embedded in the buffer matches an expected identifier
def check_schema_identifier(buffer, expected_identifer: bytes):
    if get_schema(buffer) != expected_identifer.decode():
        raise WrongSchemaException(
            f"Incorrect schema: expected {expected_identifer} but got {get_schema(buffer)}"
        )
def check_schema_identifier ( buffer , expected_identifer : bytes ) : if get_schema ( buffer ) != expected_identifer . decode ( ) : raise WrongSchemaException ( f"Incorrect schema: expected {expected_identifer} but got {get_schema(buffer)}" )
Check the schema code embedded in the buffer matches an expected identifier
Check the schema code embedded in the buffer matches an expected identifier
"""
    Check the schema code embedded in the buffer matches an expected identifier

    :param buffer: The raw buffer of the FlatBuffers message
    :param expected_identifer: The expected flatbuffer identifier
    """
buffer
The raw buffer of the FlatBuffers message
The raw buffer of the FlatBuffers message
expected_identifer
bytes
The expected flatbuffer identifier
The expected flatbuffer identifier