🚧 feat(wip): messaging

Author: mxchinegod

magnet/ic/field.py

@@ -257,6 +257,8 @@ async def listen(self, cb=print, job_n: int = None):
                     _f('success', f"job of {job_n} fulfilled")
                 except Exception as e:
                     _f('fatal', e)
+            except ValueError as e:
+                _f('warn', f'{self.session} reached the end of {self.category}, {self.stream}')
             except Exception as e:
                 _f('fatal', e)
         else: