(encodedPayload, binaryType)
| 455 | }); |
| 456 | }; |
| 457 | var decodePayload = function decodePayload(encodedPayload, binaryType) { |
| 458 | var encodedPackets = encodedPayload.split(SEPARATOR); |
| 459 | var packets = []; |
| 460 | for (var i = 0; i < encodedPackets.length; i++) { |
| 461 | var decodedPacket = decodePacket(encodedPackets[i], binaryType); |
| 462 | packets.push(decodedPacket); |
| 463 | if (decodedPacket.type === "error") { |
| 464 | break; |
| 465 | } |
| 466 | } |
| 467 | return packets; |
| 468 | }; |
| 469 | function createPacketEncoderStream() { |
| 470 | return new TransformStream({ |
| 471 | transform: function transform(packet, controller) { |
no test coverage detected