From 781d5d74f61bcef7a07edd9fdd06d4ceab7ec241 Mon Sep 17 00:00:00 2001
From: tursom <tursom@foxmail.com>
Date: Fri, 1 Mar 2024 13:16:17 +0800
Subject: [PATCH] change another way to skip stream record

---
 src/blrec/core/operators/stream_fetcher.py | 2 --
 src/blrec/flv/operators/parse.py           | 3 +--
 2 files changed, 1 insertion(+), 4 deletions(-)

diff --git a/src/blrec/core/operators/stream_fetcher.py b/src/blrec/core/operators/stream_fetcher.py
index 66b0b0b..24272c4 100644
--- a/src/blrec/core/operators/stream_fetcher.py
+++ b/src/blrec/core/operators/stream_fetcher.py
@@ -35,8 +35,6 @@ class StreamFetcher(AsyncCooperationMixin):
             scheduler: Optional[abc.SchedulerBase] = None,
         ) -> abc.DisposableBase:
             def on_next(url: str) -> None:
-                observer.on_next(io.BytesIO(b""))
-                return
                 try:
                     logger.info(f'Requesting live stream... {url}')
                     response = self._session.get(
diff --git a/src/blrec/flv/operators/parse.py b/src/blrec/flv/operators/parse.py
index 585aa9a..d4b00e8 100644
--- a/src/blrec/flv/operators/parse.py
+++ b/src/blrec/flv/operators/parse.py
@@ -28,11 +28,10 @@ def parse(
             observer: abc.ObserverBase[FLVStreamItem],
             scheduler: Optional[abc.SchedulerBase] = None,
         ) -> abc.DisposableBase:
-            disposed = False
+            disposed = True
             subscription = SerialDisposable()
 
             def on_next(stream: io.RawIOBase) -> None:
-                return
                 tag: Optional[FlvTag] = None
                 try:
                     try: