static void closeOthers ( final SimpleReactStream active , final List < SimpleReactStream > all ) { all . stream ( ) . filter ( next -> next != active ) . filter ( s -> s instanceof BaseSimpleReactStream ) . forEach ( SimpleReactStream :: cancel ) ; }
Close all streams except the active one