diff options
| author | Maksim Pechnikov <parallel588@gmail.com> | 2020-09-16 09:47:18 +0300 |
|---|---|---|
| committer | Maksim Pechnikov <parallel588@gmail.com> | 2020-09-16 09:47:18 +0300 |
| commit | 599f8bb152ca0669d17baa5f313f00f0791209b6 (patch) | |
| tree | 9bc4e08bdc2a0c78ba773775dc11a17c9e0350d1 /lib/pleroma/user.ex | |
| parent | c74fad9e06cdb272a1378082908448f7f0b592ac (diff) | |
| download | pleroma-599f8bb152ca0669d17baa5f313f00f0791209b6.tar.gz | |
RepoStreamer.chunk_stream -> Repo.chunk_stream
Diffstat (limited to 'lib/pleroma/user.ex')
| -rw-r--r-- | lib/pleroma/user.ex | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/lib/pleroma/user.ex b/lib/pleroma/user.ex index e73d19964..57497eb83 100644 --- a/lib/pleroma/user.ex +++ b/lib/pleroma/user.ex @@ -25,7 +25,6 @@ defmodule Pleroma.User do alias Pleroma.Object alias Pleroma.Registration alias Pleroma.Repo - alias Pleroma.RepoStreamer alias Pleroma.User alias Pleroma.UserRelationship alias Pleroma.Web @@ -1775,7 +1774,7 @@ defmodule Pleroma.User do def delete_user_activities(%User{ap_id: ap_id} = user) do ap_id |> Activity.Queries.by_actor() - |> RepoStreamer.chunk_stream(50) + |> Repo.chunk_stream(50, :batches) |> Stream.each(fn activities -> Enum.each(activities, fn activity -> delete_activity(activity, user) end) end) |