Skip to content
Snippets Groups Projects
Commit 82b4c08b authored by Yun-Jing Huang's avatar Yun-Jing Huang
Browse files

Merge branch 'remove-internal-pad' into 'main'

remove internal pad

See merge request !80
parents ef1e5cf9 2d910277
No related branches found
No related tags found
1 merge request!80remove internal pad
Pipeline #686111 passed
......@@ -4,14 +4,7 @@ from dataclasses import dataclass
from math import isinf
from typing import Optional, Union
from sgn.base import (
InternalPad,
SinkElement,
SinkPad,
SourceElement,
SourcePad,
TransformElement,
)
from sgn.base import SinkElement, SinkPad, SourceElement, SourcePad, TransformElement
from sgnts.base.array_ops import Array, ArrayBackend, NumpyBackend
from sgnts.base.audioadapter import Audioadapter
......@@ -251,7 +244,7 @@ class _TSTransSink:
return preparedbufs
def internal(self, pad: InternalPad) -> None:
def internal(self) -> None:
"""Align buffers from all the sink pads.
If AdapterConfig is provided, perform the requested
......@@ -379,8 +372,8 @@ class TSTransform(TransformElement, _TSTransSink):
TransformElement.__post_init__(self)
_TSTransSink.__post_init__(self)
def internal(self, pad: InternalPad):
_TSTransSink.internal(self, pad)
def internal(self):
_TSTransSink.internal(self)
def transform(self, pad: SourcePad) -> TSFrame:
"""The transform function must be provided by the subclass.
......@@ -409,8 +402,8 @@ class TSSink(SinkElement, _TSTransSink):
SinkElement.__post_init__(self)
_TSTransSink.__post_init__(self)
def internal(self, pad: InternalPad):
_TSTransSink.internal(self, pad)
def internal(self):
_TSTransSink.internal(self)
@dataclass
......
from dataclasses import dataclass
import numpy as np
from sgn.base import InternalPad
from sgnts.base import Time, TSSink
......@@ -17,14 +16,9 @@ class FakeSeriesSink(TSSink):
verbose: bool = False
def internal(self, pad: InternalPad) -> None:
"""Print frames if verbose.
Args:
pad:
InternalPad, the internal pad
"""
super().internal(pad)
def internal(self) -> None:
"""Print frames if verbose."""
super().internal()
for sink_pad in self.sink_pads:
frame = self.preparedframes[sink_pad]
if frame.EOS:
......@@ -82,14 +76,9 @@ class DumpSeriesSink(TSSink):
with open(self.fname, "a") as f:
np.savetxt(f, out)
def internal(self, pad: InternalPad) -> None:
"""Write out time-series data.
Args:
pad:
InternalPad
"""
super().internal(pad)
def internal(self) -> None:
"""Write out time-series data."""
super().internal()
sink_pad = self.sink_pad
frame = self.preparedframes[sink_pad]
if frame.EOS:
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment