@ SuppressWarnings ( "unchecked" ) < T extends Action > EventStream < T > getActionStream ( Class < T > actionType ) { return Dispatcher . getInstance ( ) . getActionStream ( ) . filter ( action -> action . getClass ( ) . equals ( actionType ) ) . map ( action -> ( T ) action ) ; }
A filtered event - stream of actions of the given type .