ReferentialGym.utils.streamHandler package¶
Submodules¶
ReferentialGym.utils.streamHandler.StreamHandler module¶
-
class
ReferentialGym.utils.streamHandler.StreamHandler.StreamHandler¶ Bases:
object-
register(placeholder_id: str)¶
-
reset(placeholder_id: str)¶
-
update(placeholder_id: str, stream_data: Dict[str, object], p_ptr: Dict[str, object] = None, reset=False)¶ Updates the streams of a given placeholder. Hierarchically explores the placeholders and their streams.
- Params placeholder_id
string formatted with ‘:’ between the name of the streaming module/placeholder and the name of the stream.
- Parameters
stream_data – data or dict of str and torch.Tensor/List to update the stream with.
p_ptr – None, except when called by self in a recurrent fashion.
-
serve(pipeline: List[object])¶
-
_serve_module(module: object)¶
-
_operate(data: object, operations: List[str]) → object¶
-