@@ -3,7 +3,7 @@ use std::time::Duration;
33use bevy_app:: { App , AppExit , Last , Plugin , PreStartup , PreUpdate } ;
44pub use bevy_color:: { Color , ColorToComponents , LinearRgba } ;
55use bevy_ecs:: {
6- event :: { Event , EventReader , EventWriter } ,
6+ message :: { Message , MessageReader , MessageWriter } ,
77 resource:: Resource ,
88 system:: { Commands , Res , ResMut } ,
99} ;
@@ -22,7 +22,7 @@ pub struct StreamDeckPlugin;
2222
2323impl Plugin for StreamDeckPlugin {
2424 fn build ( & self , app : & mut App ) {
25- app. add_event :: < StreamDeckInput > ( )
25+ app. add_message :: < StreamDeckInput > ( )
2626 . init_resource :: < ButtonInput < StreamDeckKey > > ( )
2727 . add_systems ( PreStartup , listener)
2828 . add_systems ( PreUpdate , receiver)
@@ -33,7 +33,7 @@ impl Plugin for StreamDeckPlugin {
3333#[ derive( Clone , Copy , Hash , PartialEq , Eq ) ]
3434pub struct StreamDeckKey ( pub u8 ) ;
3535
36- #[ derive( Event , Debug ) ]
36+ #[ derive( Message , Debug ) ]
3737pub enum StreamDeckInput {
3838 Press ( u8 ) ,
3939 Release ( u8 ) ,
@@ -122,11 +122,11 @@ fn listener(mut commands: Commands) {
122122 if lost_connection {
123123 streamdeck = None ;
124124 }
125- if streamdeck. is_none ( ) {
126- if let Ok ( new_streamdeck) = streamdeck:: StreamDeck :: connect ( 0x0fd9 , 0x0063 , None ) {
127- let _ = event_tx . send ( StreamDeckEvent :: Connected ( new_streamdeck . kind ( ) ) ) ;
128- streamdeck = Some ( new_streamdeck) ;
129- }
125+ if streamdeck. is_none ( )
126+ && let Ok ( new_streamdeck) = streamdeck:: StreamDeck :: connect ( 0x0fd9 , 0x0063 , None )
127+ {
128+ let _ = event_tx . send ( StreamDeckEvent :: Connected ( new_streamdeck. kind ( ) ) ) ;
129+ streamdeck = Some ( new_streamdeck ) ;
130130 }
131131 }
132132 } ) ;
@@ -142,7 +142,7 @@ fn receiver(
142142 mut streamdeck : ResMut < StreamDeck > ,
143143 internal : Res < StreamDeckInternal > ,
144144 mut inputs : ResMut < ButtonInput < StreamDeckKey > > ,
145- mut input_events : EventWriter < StreamDeckInput > ,
145+ mut input_events : MessageWriter < StreamDeckInput > ,
146146) {
147147 inputs. clear ( ) ;
148148 for from_stream in internal. events . try_iter ( ) {
@@ -262,7 +262,7 @@ impl StreamDeck {
262262 }
263263}
264264
265- fn exit_on_exit ( streamdeck : Res < StreamDeck > , mut exit_events : EventReader < AppExit > ) {
265+ fn exit_on_exit ( streamdeck : Res < StreamDeck > , mut exit_events : MessageReader < AppExit > ) {
266266 if exit_events. read ( ) . next ( ) . is_some ( ) {
267267 let _ = streamdeck. orders . send ( StreamDeckOrder :: Reset ) ;
268268 let _ = streamdeck. orders . send ( StreamDeckOrder :: Exit ) ;
0 commit comments