#NEWLINE# @ idiokit . stream #NEWLINE# def session( self , _ , src_room , dst_room , **keys ) : #NEWLINE# #INDENT# keyset = ( yield idiokit . pipe ( self . transform_keys ( src_room = src_room , dst_room = dst_room , ** keys ) , _collect_set ( ) ) ) #NEWLINE# pipes = [ self . _pipes . inc ( src_room , dst_room , key ) for key in pipes ] #NEWLINE# ( yield idiokit . pipe ( * pipes ) )