(encodedPayload, binaryType)
| 368 | }); |
| 369 | }; |
| 370 | var decodePayload = function decodePayload(encodedPayload, binaryType) { |
| 371 | var encodedPackets = encodedPayload.split(SEPARATOR); |
| 372 | var packets = []; |
| 373 | for (var i = 0; i < encodedPackets.length; i++) { |
| 374 | var decodedPacket = decodePacket(encodedPackets[i], binaryType); |
| 375 | packets.push(decodedPacket); |
| 376 | if (decodedPacket.type === "error") { |
| 377 | break; |
| 378 | } |
| 379 | } |
| 380 | return packets; |
| 381 | }; |
| 382 | function createPacketEncoderStream() { |
| 383 | return new TransformStream({ |
| 384 | transform: function transform(packet, controller) { |
no test coverage detected