ó §‰]c@sYdZddlZddlZddlmZd„ZejdƒZed„ƒZdS(sHPreprocessor for merging consecutive stream outputs for easier handling.i˙˙˙˙N(t get_loggercs"tjˆƒ‡fd†ƒ}|S(s  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 cs_tƒjdˆjƒx<t|jƒD]+\}}ˆ|||ƒ\|j|<}q&W||fS(NsApplying preprocessor: %s(Rtdebugt__name__t enumeratetcells(tnbt resourcestindextcell(tfunction(sFlib/python2.7/site-packages/nbconvert/preprocessors/coalescestreams.pyt wrappedfuncs   #(t functoolstwraps(R R ((R sFlib/python2.7/site-packages/nbconvert/preprocessors/coalescestreams.pytcell_preprocessor ss .*\r(?=[^\n])cCs˙|jdgƒ}|s"||fS|d}|g}xj|dD]^}|jdkr‹|jdkr‹|j|jkr‹|j|j7_q@|j|ƒ|}q@WxG|D]?}|jdkrİd|jkrİtjd|jƒ|_qİqİW||_||fS(s½ 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 toutputsiitstreams t(tgett output_typetnamettexttappendtcr_pattsubR(RRRRtlastt new_outputstoutput((sFlib/python2.7/site-packages/nbconvert/preprocessors/coalescestreams.pytcoalesce_streams$s"       ( t__doc__treR t traitlets.logRR tcompileRR(((sFlib/python2.7/site-packages/nbconvert/preprocessors/coalescestreams.pyts