Fix streams signatures

dist/metacom.js

@@ -64,9 +64,8 @@ class Metacom extends EventEmitter {
 
   createStream(name, size) {
     const id = ++this.streamId;
-    const initData = { type: 'stream', id, name, size };
     const transport = this;
-    return new MetaWritable(transport, initData);
+    return new MetaWritable(id, name, size, transport);
   }
 
   createBlobUploader(blob) {
@@ -123,8 +122,7 @@ class Metacom extends EventEmitter {
         if (stream) {
           console.error(new Error(`Stream ${name} is already initialized`));
         } else {
-          const streamData = { id, name, size };
-          const stream = new MetaReadable(streamData);
+          const stream = new MetaReadable(id, name, size);
           this.streams.set(id, stream);
         }
       } else if (!stream) {

dist/streams.js

@@ -132,12 +132,12 @@ class MetaReadable extends EventEmitter {
 }
 
 class MetaWritable extends EventEmitter {
-  constructor(transport, options = {}) {
+  constructor(id, name, size, transport) {
     super();
+    this.id = id;
+    this.name = name;
+    this.size = size;
     this.transport = transport;
-    this.id = options.id;
-    this.name = options.name;
-    this.size = options.size;
     this.init();
   }
 

lib/client.js

@@ -63,7 +63,7 @@ class Metacom extends EventEmitter {
 
   createStream(name, size) {
     const id = ++this.streamId;
-    return new MetaWritable(this, { id, name, size });
+    return new MetaWritable(id, name, size, this);
   }
 
   createBlobUploader(blob) {

lib/server.js

@@ -106,8 +106,7 @@ class Client extends EventEmitter {
     if (!name) throw new Error('Stream name is not provided');
     if (!size) throw new Error('Stream size is not provided');
     const id = --this.#streamId;
-    const packet = { id, name, size };
-    const stream = new MetaWritable(this.#transport, packet);
+    const stream = new MetaWritable(id, name, size, this.#transport);
     this.streams.set(id, stream);
     return stream;
   }
@@ -296,7 +295,7 @@ class Server {
       if (!valid) throw new Error('Stream packet structure error');
       if (stream) throw new Error(`Stream ${tag} is already initialized`);
       {
-        const stream = new MetaReadable({ id, name, size });
+        const stream = new MetaReadable(id, name, size);
         client.streams.set(id, stream);
         this.console.log(`${client.ip}\tstream ${tag} init`);
       }

lib/streams.js

@@ -132,12 +132,12 @@ class MetaReadable extends EventEmitter {
 }
 
 class MetaWritable extends EventEmitter {
-  constructor(transport, options = {}) {
+  constructor(id, name, size, transport) {
     super();
+    this.id = id;
+    this.name = name;
+    this.size = size;
     this.transport = transport;
-    this.id = options.id;
-    this.name = options.name;
-    this.size = options.size;
     this.init();
   }
 

test/streams.js

@@ -36,7 +36,7 @@ const createWritable = (id, name, size) => {
     send: (packet) => writeBuffer.push(JSON.stringify(packet)),
     write: (data) => writeBuffer.push(data),
   };
-  const stream = new MetaWritable(transport, { id, name, size });
+  const stream = new MetaWritable(id, name, size, transport);
   return [stream, writeBuffer];
 };