     %{stream | models: loaded}
   end
 
-  defp async_fetch_subjects({type, items}, %{current_user: current_user}) do
-    ids = items
-          |> Enum.map(&(&1.subject_id))
-          |> Enum.dedup
-    Task.async(__MODULE__, :fetch_subjects, [type, ids, current_user])
-  end
-
+  @user_preloads %{current_user_state: %{}}
   @post_preloads %{
     assets: %{},
     author: @user_preloads,

  @category_user_preloads %{user: @user_preloads, category: %{}}
  @category_post_preloads %{post: @post_preloads, category: %{}}
  @artist_invite_submission_preloads %{post: @post_preloads, artist_invite: %{}}

  def fetch_subjects("Post", ids, user) do
    {"Post", Content.posts(%{

    Map.put(stream, :models, items)
  end


  defp load_related(%{models: items} = stream) do
    subjects = preload_subjects(stream)
    users = preload_orignating_users(stream)

    loaded = Enum.map(items, &Map.merge(&1, %{
      subject: subjects[&1.subject_type][&1.subject_id],
