mantis-network/src/main/java/io/reactivex/mantis/network/push/LegacyTcpPipelineConfigurator.java [223:240]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private void writeHeader(ByteBuf buf, String name) {
        buf.writeByte(PROTOCOL_VERSION);
        String observableName = name;
        if (observableName != null && !observableName.isEmpty()) {
            // write length
            int nameLength = observableName.length();
            if (nameLength < 127) {
                buf.writeByte(nameLength);
                buf.writeBytes(observableName.getBytes());
            } else {
                throw new RuntimeException("observableName " + observableName +
                        " exceeds max limit of 127 characters");
            }
        } else {
            // no name provided, write 0 bytes for name length
            buf.writeByte(0);
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/BatchedRxEventPipelineConfigurator.java [210:227]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private void writeHeader(ByteBuf buf, String name) {
        buf.writeByte(PROTOCOL_VERSION);
        String observableName = name;
        if (observableName != null && !observableName.isEmpty()) {
            // write length
            int nameLength = observableName.length();
            if (nameLength < 127) {
                buf.writeByte(nameLength);
                buf.writeBytes(observableName.getBytes());
            } else {
                throw new RuntimeException("observableName " + observableName +
                        " exceeds max limit of 127 characters");
            }
        } else {
            // no name provided, write 0 bytes for name length
            buf.writeByte(0);
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -