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

Method items

faust/types/streams.py:153–153  ·  view source on GitHub ↗
(self)

Source from the content-addressed store, hash-verified

151 @abc.abstractmethod
152 @no_type_check
153 async def items(self) -> AsyncIterator[Tuple[K, T_co]]: ...
154
155 @abc.abstractmethod
156 @no_type_check

Callers 15

merge_headersFunction · 0.45
setting_namesMethod · 0.45
_init_settingsMethod · 0.45
build_closure_sourceFunction · 0.45
reprkwargsFunction · 0.45
translateFunction · 0.45
dict_as_ansitableFunction · 0.45
map_from_recordsMethod · 0.45
records_iteratorMethod · 0.45
commitMethod · 0.45
perform_seekMethod · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected