Remove TODO

core/bin/zksync_event_listener/src/listener.rs

@@ -45,6 +45,7 @@ impl StreamHandler<NotifyResult> for EventListener {
         let pool = self.db_pool.clone();
         let last_processed_event_id = self.last_processed_event_id;
         async move {
+            // Try to fetch and deserialize new events.
             Ok(pool
                 .access_storage()
                 .await?
@@ -86,8 +87,6 @@ impl StreamHandler<NotifyResult> for EventListener {
                         err
                     );
                 }
-                // The server monitor doesn't have a timeout on its
-                // mailbox, thus, stop the context no matter what.
                 if shutdown {
                     ctx.stop();
                 }

core/bin/zksync_event_listener/src/main.rs

@@ -5,11 +5,8 @@ fn main() {
     let _sentry_guard = vlog::init();
     let config = ZkSyncConfig::from_env();
 
-    // TODO: `stop_on_panic` has no effect cause of tokio implementation.
-    // Instead, the server should shutdown itself in case of an error. (ZKS-654).
     let mut sys = actix_web::rt::System::builder()
         .name("event-listener")
-        .stop_on_panic(true)
         .build();
 
     sys.block_on(run_event_server(config));

core/bin/zksync_event_listener/src/subscriber/mod.rs

@@ -155,6 +155,7 @@ impl Handler<Shutdown> for Subscriber {
             description: Some("internal server error".to_string()),
         });
         ctx.close(reason);
+        // No need to notify the monitor, stop the context right away.
         ctx.stop();
     }
 }