@@ -77,9 +77,7 @@ impl EventHub {
77
77
78
78
{
79
79
let mut listeners = self . listeners . write ( ) . unwrap ( ) ;
80
- let event_listeners = listeners
81
- . entry ( event_id. clone ( ) )
82
- . or_default ( ) ;
80
+ let event_listeners = listeners. entry ( event_id. clone ( ) ) . or_default ( ) ;
83
81
event_listeners. insert ( callback_name, callback) ;
84
82
}
85
83
@@ -145,7 +143,10 @@ impl EventHub {
145
143
let all_listeners = self . all_listeners . read ( ) . unwrap ( ) ;
146
144
for callback in all_listeners. iter ( ) {
147
145
// Create minimal tuple for global listeners: (event_id, args)
148
- let global_args = ( event_id. to_string ( ) . into_pyobject ( py) . unwrap ( ) , args. clone_ref ( py) ) ;
146
+ let global_args = (
147
+ event_id. to_string ( ) . into_pyobject ( py) . unwrap ( ) ,
148
+ args. clone_ref ( py) ,
149
+ ) ;
149
150
150
151
if let Err ( e) = callback. call1 ( py, global_args) {
151
152
// Check if we should raise exceptions based on config._raise
@@ -269,7 +270,10 @@ impl EventHub {
269
270
{
270
271
let all_listeners = self . all_listeners . read ( ) . unwrap ( ) ;
271
272
for ( idx, callback) in all_listeners. iter ( ) . enumerate ( ) {
272
- let global_args = ( event_id. to_string ( ) . into_pyobject ( py) . unwrap ( ) , args. clone_ref ( py) ) ;
273
+ let global_args = (
274
+ event_id. to_string ( ) . into_pyobject ( py) . unwrap ( ) ,
275
+ args. clone_ref ( py) ,
276
+ ) ;
273
277
let listener_name = format ! ( "__global_listener_{}" , idx) ;
274
278
275
279
let result = match callback. call1 ( py, global_args) {
0 commit comments