Skip to content

Commit

Permalink
Helpful comments added.
Browse files Browse the repository at this point in the history
  • Loading branch information
trishaanand committed Dec 30, 2020
1 parent b43da4e commit 300bcd0
Showing 1 changed file with 2 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -679,6 +679,8 @@ public Mono<List<User>> inviteUsers(InviteUsersDTO inviteUsersDTO, String origin
Mono<List<User>> triggerAddUserOrganizationFinalFlowMono = organizationWithUsersAddedMono
.then(usersUpdatedWithOrgMono);

// Use a synchronous sink which does not take subscription cancellations into account. This that even if the
// subscriber has cancelled its subscription, the create method will still generates its event.
return Mono.create(sink -> triggerAddUserOrganizationFinalFlowMono
.subscribe(sink::success, sink::error, null, sink.currentContext())
);
Expand Down

0 comments on commit 300bcd0

Please sign in to comment.