Unify event bus unary/streaming cases - #298

Merged

vietj merged 21 commits into

mainfrom

refactor-3

Aug 17, 2026

Commits on Aug 17, 2026

Use a unique stream id for the stream.
vietj
committed
1bc9d99
Use a single producer at the registration's remote endpoint level.
vietj
committed
5a46d37
Factor sendTransportFrame to StreamRegistration
vietj
committed
d944510
Minor cleanup
vietj
committed
4de4b99
Move common registration to stream base
vietj
committed
cc70eb8
Make registration final
vietj
committed
16cba64
Add local/remote unary flag in stream base
vietj
committed
c16ffa2
Guard case that should not be possible
vietj
committed
da966c6
Client unary should return a future reflecting the state of the write operation
vietj
committed
be98e4b
Actually unary sends the message on end signal
vietj
committed
0120062
Encapsulate client streaming call outbound part in an inner class
vietj
committed
367fb71
The future returned by streaming call open should only reflect the state of the write to the remote peer not the success of the interaction
vietj
committed
931ecae
Port the unary client to server call to streaming implementation so that client unary / server streaming are handled.
vietj
committed
1fd0f7a
Encapsulate outbound behavior in streaming server class
vietj
committed
b3a374a
Import the unary behavior in the streaming client class
vietj
committed
fdba2bf
Import the unary behavior in the server client class
vietj
committed
2ef4bc0
Make outbound field final
vietj
committed
3ee3807
Correctly map the event-bus failure to the grpc status exception
vietj
committed
ff70ead
Remove EventBusGrpcServerUnaryCall that is not needed anymore
vietj
committed
0524e4b
Rename streaming class that actually handle both cases now
vietj
committed
6be2234
Update spec
vietj
committed
a008450

Navigation Menu

Uh oh!

Unify event bus unary/streaming cases - #298

Unify event bus unary/streaming cases#298
vietj merged 21 commits into
mainfrom
refactor-3

Commits on Aug 17, 2026

Use a unique stream id for the stream.

Use a single producer at the registration's remote endpoint level.

Factor sendTransportFrame to StreamRegistration

Minor cleanup

Move common registration to stream base

Make registration final

Add local/remote unary flag in stream base

Guard case that should not be possible

Client unary should return a future reflecting the state of the write operation

Actually unary sends the message on end signal

Encapsulate client streaming call outbound part in an inner class

The future returned by streaming call open should only reflect the state of the write to the remote peer not the success of the interaction

Port the unary client to server call to streaming implementation so that client unary / server streaming are handled.

Encapsulate outbound behavior in streaming server class

Import the unary behavior in the streaming client class

Import the unary behavior in the server client class

Make outbound field final

Correctly map the event-bus failure to the grpc status exception

Remove EventBusGrpcServerUnaryCall that is not needed anymore

Rename streaming class that actually handle both cases now

Update spec