tursom/blrec
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

change another way to skip stream record

Browse Source
This commit is contained in:
tursom 2024-03-01 13:16:17 +08:00
parent fb337b4b83
commit 781d5d74f6
2 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/blrec/core/operators/stream_fetcher.py
View File

@ -35,8 +35,6 @@ class StreamFetcher(AsyncCooperationMixin):
scheduler: Optional[abc.SchedulerBase] = None, scheduler: Optional[abc.SchedulerBase] = None,
) -> abc.DisposableBase: ) -> abc.DisposableBase:
def on_next(url: str) -> None: def on_next(url: str) -> None:
observer.on_next(io.BytesIO(b""))
return
try: try:
logger.info(f'Requesting live stream... {url}') logger.info(f'Requesting live stream... {url}')
response = self._session.get( response = self._session.get(

3
src/blrec/flv/operators/parse.py
View File

@ -28,11 +28,10 @@ def parse(
observer: abc.ObserverBase[FLVStreamItem], observer: abc.ObserverBase[FLVStreamItem],
scheduler: Optional[abc.SchedulerBase] = None, scheduler: Optional[abc.SchedulerBase] = None,
) -> abc.DisposableBase: ) -> abc.DisposableBase:
disposed = False disposed = True
subscription = SerialDisposable() subscription = SerialDisposable()
def on_next(stream: io.RawIOBase) -> None: def on_next(stream: io.RawIOBase) -> None:
return
tag: Optional[FlvTag] = None tag: Optional[FlvTag] = None
try: try:
try: try: