b^dZddlZddlZddlmZdZej dZedZy)zHPreprocessor for merging consecutive stream outputs for easier handling.N) get_loggercBtjfd}|S)a Wrap a function to be executed on all cells of a notebook The wrapped function should have these parameters: cell : NotebookNode cell Notebook cell being processed resources : dictionary Additional resources used in the conversion process. Allows preprocessors to pass variables into the Jinja engine. index : int Index of the cell being processed ctjdjt|jD]\}}|||\|j|<}!||fS)NzApplying preprocessor: %s)rdebug__name__ enumeratecells)nb resourcesindexcellfunctions I/usr/lib/python3/dist-packages/nbconvert/preprocessors/coalescestreams.py wrappedfuncz&cell_preprocessor..wrappedfuncs_ 68I8IJ$RXX. JKE4)1$ 5)I &BHHUOY J9}) functoolswraps)rrs` rcell_preprocessorr s(__X rz .*\r(?=[^\n])c|jdg}|s||fS|d}|g}|ddD]l}|jdk(rH|jdk(r9|j|jk(r |xj|jz c_Z|j ||}n|D]F}|jdk(sd|jvs"t j d|j|_H||_||fS)a Merge consecutive sequences of stream output into single stream to prevent extra newlines inserted at flush calls Parameters ---------- cell : NotebookNode cell Notebook cell being processed resources : dictionary Additional resources used in the conversion process. Allows transformers to pass variables into the Jinja engine. index : int Index of the cell being processed outputsrNstream )get output_typenametextappendcr_patsubr)r r r rlast new_outputsoutputs rcoalesce_streamsr%(s"hhy"%G Y 1:D&K!"+    ( *  H, V[[( II $I   v &D 6    )dfkk.A **R5FK6DL ?r) __doc__rre traitlets.logrrcompiler r%rrr+s?N  $2 $ %((r