code: @SuppressWarnings("unchecked")
      public static <T> StreamingProcess<T> getStreamingProcess(T entity, InjectionManager manager) {
          for (StreamingProcess process : getStreamingProcesses(manager)) {
              if (process.isSupported(entity)) {
                  return process;
              }
          }
          return null;
      }
docs: <p>getStreamingProcess.</p>
  
  @param entity a T object.
  @param manager manager
  @param <T> a T object.
  @return a {@link ameba.message.internal.StreamingProcess} object.