MCPcopy
hub / github.com/faust-streaming/faust / get_codec

Function get_codec

faust/serializers/codecs.py:340–355  ·  view source on GitHub ↗

Get codec by name.

(name_or_codec: CodecArg)

Source from the content-addressed store, hash-verified

338
339
340def get_codec(name_or_codec: CodecArg) -> CodecT:
341 """Get codec by name."""
342 _maybe_load_extension_classes()
343 if isinstance(name_or_codec, str):
344 if "|" in name_or_codec:
345 nodes = name_or_codec.split("|")
346 codec = None
347 for node in nodes:
348 if codec:
349 codec |= codecs[node]
350 else:
351 codec = codecs.get(node, node)
352
353 return cast(Codec, codec)
354 return codecs[name_or_codec]
355 return cast(Codec, name_or_codec)
356
357
358def dumps(codec: Optional[CodecArg], obj: Any) -> bytes:

Callers 6

test_get_codecFunction · 0.90
test_registerFunction · 0.90
test_rawFunction · 0.90
dumpsFunction · 0.85
loadsFunction · 0.85

Calls 2

getMethod · 0.45

Tested by 4

test_get_codecFunction · 0.72
test_registerFunction · 0.72
test_rawFunction · 0.72