code: public Stream add(StreamFragmentBean msg) {
          Stream stream = streamCache.getUnchecked(msg.getHeader().getId());
          stream.add(msg);
          return stream;
      }
docs: 从入参片段中获取流对象并返回，如果片段属于相同的流，返回的的stream也是同一个，如果是流开头，那么pair的第二个值就是true，否则
  
  @param msg 必须遵循stream协议的片段字符串