Skip to content

Commit

Permalink
reorganise stream.go
Browse files Browse the repository at this point in the history
  • Loading branch information
rusq committed Mar 18, 2023
1 parent 028ca27 commit 63cc839
Show file tree
Hide file tree
Showing 2 changed files with 154 additions and 160 deletions.
4 changes: 2 additions & 2 deletions internal/chunk/transform/fetch.go
Original file line number Diff line number Diff line change
Expand Up @@ -72,8 +72,8 @@ func Fetch(ctx context.Context, sess streamer, dir string, link string, p *Param
}
}()
if err := sess.Stream(
slackdump.WithLatest(p.Latest),
slackdump.WithOldest(p.Oldest),
slackdump.OptLatest(p.Latest),
slackdump.OptOldest(p.Oldest),
).Conversations(ctx, pr, link); err != nil {
return statefile, err
}
Expand Down
Loading

0 comments on commit 63cc839

Please sign in to comment.