docs: public static SubscriberState read(DataInput dataInput) throws IOException {
          return SubscriberState.builder().isMaster(dataInput.readBoolean()).serverState(dataInput.readUTF())
                          .totalUpdates(dataInput.readInt()).streamId(dataInput.readInt()).build();
      }