Possible faster version of chunk_on

[CodyKochmann]

Test to see if this version of chunk_on has mo powah than the previous version using deques.

# -*- coding: utf-8 -*-
# @Author: Cody Kochmann

from itertools import groupby, chain

def chunk_on(pipeline, new_chunk_signal, output_type=tuple):
    ''' split the stream into seperate chunks based on a new chunk signal '''
    assert callable(new_chunk_signal), 'chunks needs new_chunk_signal to be callable'
    assert callable(output_type), 'chunks needs output_type to be callable'
    
    holder = None
    for signal, group in groupby(pipeline, new_chunk_signal):
        if signal:
            for i in group:
                holder = [i]
                break
            for i in group:
                yield output_type(holder)
                holder = [i]
        else:
            if holder is None:
                yield output_type(group)
            else:
                yield output_type(chain(holder, group))
                holder = None
    if holder:
        yield output_type(holder)

[CodyKochmann]

This one might be faster as well...

# -*- coding: utf-8 -*-
# @Author: Cody Kochmann

from itertools import groupby, chain

def chunk_on(pipeline, new_chunk_signal, output_type=tuple):
    ''' split the stream into seperate chunks based on a new chunk signal '''
    assert callable(new_chunk_signal), 'chunks needs new_chunk_signal to be callable'
    assert callable(output_type), 'chunks needs output_type to be callable'
    
    holder = []
    
    for signal, group in groupby(pipeline, new_chunk_signal):
        if signal:
            for i in group:
                holder = [i]
                break
            for i in group:
                yield output_type(holder)
                holder = [i]
        else:
            yield output_type(
                chain(
                    holder, 
                    group
                )
            )
            holder = []
    if holder:
        yield output_type(holder)