-
Notifications
You must be signed in to change notification settings - Fork 161
Add an interceptor for listExecutions #2524
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
base: master
Are you sure you want to change the base?
Conversation
5201ff1
to
ae69317
Compare
@@ -11,14 +11,14 @@ | |||
import javax.annotation.Nonnull; | |||
import javax.annotation.Nullable; | |||
|
|||
class ListWorkflowExecutionIterator | |||
public class ListWorkflowExecutionIterator |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Does this need to be public to support the interceptor? In .NET for example we felt there was no need to expose the underlying machinery of list workflows because creating an async iterator (or Java stream) should be easy enough if they must completely replace the logic and not just delegate to the next interceptor.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
ideally no, the problem is the RootWorkflowClientInvoker.java is in internal so it can't be private, moving this class causes a lot of other issues
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
moving this class causes a lot of other issues
Hrmm. I wonder making public and moving from io.temporal.client
to io.temporal.client.internal
would make sense.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Let me try, I think I had some issue doing that since some other classes in io.temporal.client
also have Iterators
Add an interceptor for listExecutions
closes #2328