Skip to content

[Deprecated] Extract streaming from GAgentBase.#80

Open
eanzhao wants to merge 9 commits intodevfrom
feature/stream-refactor
Open

[Deprecated] Extract streaming from GAgentBase.#80
eanzhao wants to merge 9 commits intodevfrom
feature/stream-refactor

Conversation

@eanzhao
Copy link
Contributor

@eanzhao eanzhao commented Mar 24, 2025

No description provided.

@eanzhao eanzhao changed the title Add a new stream for children on GAgent [WIP] Add a new stream for children on GAgent Mar 26, 2025
public const string StateHandlerDefaultMethodName = "HandleStateAsync";
public const string ConfigDefaultMethodName = "PerformConfigAsync";
public const string ForwardEventMethodName = "ForwardEventAsync";
public const int EventDispatcherMaxBatchSize = 20;
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I can't find the use of this anywhere

}

private IAsyncStream<EventWrapperBase> GetEventBaseStream(GrainId grainId)
private IAsyncStream<EventWrapperBase> GetEventBaseStreamForOwn(GrainId grainId)
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This naming convention is very difficult to understand. Can't really explain how for own is linked to its implementation.

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

How about changing it to GetEventBaseUpwardsStream?

}

private IAsyncStream<StateWrapper<TState>> GetStateProjectionStream()
private IAsyncStream<EventWrapperBase> GetEventBaseStreamForChildren(GrainId grainId)
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

GetEventBaseDownwardStream what do you think?

@eanzhao eanzhao changed the title [WIP] Add a new stream for children on GAgent Add a new stream for children on GAgent Mar 26, 2025
@eanzhao eanzhao changed the title Add a new stream for children on GAgent [WIP] Extract streaming from GAgentBase. Apr 2, 2025
@eanzhao eanzhao force-pushed the feature/stream-refactor branch from ec41571 to 6b45438 Compare April 3, 2025 10:18
@eanzhao eanzhao changed the title [WIP] Extract streaming from GAgentBase. Extract streaming from GAgentBase. Apr 7, 2025
@eanzhao eanzhao force-pushed the feature/stream-refactor branch from 36b8b31 to e188a82 Compare April 7, 2025 08:55
@arg-foo arg-foo changed the title Extract streaming from GAgentBase. [Deprecated] Extract streaming from GAgentBase. Apr 8, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants