diff --git a/geomagio/edge/MiniSeedInputClient.py b/geomagio/edge/MiniSeedInputClient.py index 122b1eb4ec657b339e580a0d0025042bada5f680..cadd6b508adc7198f625809cb514dd7d8dcf730a 100644 --- a/geomagio/edge/MiniSeedInputClient.py +++ b/geomagio/edge/MiniSeedInputClient.py @@ -18,9 +18,10 @@ class MiniSeedInputClient(object): MiniSeedServer port """ - def __init__(self, host, port=2061): + def __init__(self, host, port=2061, encoding="FLOAT32"): self.host = host self.port = port + self.encoding = encoding self.socket = None def close(self): @@ -71,6 +72,6 @@ class MiniSeedInputClient(object): self.connect() # convert stream to miniseed buf = io.BytesIO() - stream.write(buf, format="MSEED", reclen=512) + stream.write(buf, encoding=self.encoding, format="MSEED", reclen=512) # send data self.socket.sendall(buf.getvalue())