StreamWrapper

class torch.utils.data.datapipes.utils.common.StreamWrapper(file_obj, parent_stream=None, name=None)

StreamWrapper is introduced to wrap file handler generated by DataPipe operation like FileOpener.

StreamWrapper would guarantee the wrapped file handler is closed when it’s out of scope.

autoclose()

Automatically close stream when all child streams are closed or if there are none.

classmethod close_streams(v, depth=0)

Traverse structure and attempts to close all found StreamWrappers on best effort basis.