nogipx / rpc_dart / 25262743991

77%

Build Type

push

github

Committed by nogipx

Commit Message

feat: add RpcPeerEndpoint, RpcPeerContract, extract RpcResponderPipelineMixin, and peer codegen

- RpcPeerEndpoint: bidirectional endpoint where either side can initiate
  calls; uses stream ID parity to route incoming vs outgoing messages
  without conflicts on a single shared transport

- RpcPeerContract: base class combining RpcResponderContract (addXxxMethod
  handlers) with caller methods (callUnary/callServerStream/etc.) bound
  to RpcPeerEndpoint

- RpcServiceKind enum: unidirectional (default, Caller+Responder) or peer
  (Peer only); added kind parameter to @RpcService annotation

- Generator: emits abstract XxxPeer class when kind: RpcServiceKind.peer;
  caller methods implement the interface (outgoing calls), abstract onXxx
  methods are handler stubs for incoming calls from the remote peer

- Refactor: extract RpcResponderPipelineMixin (message routing, responder
  creation, stream lifecycle, cleanup) and RpcCallerPipelineMixin
  (cancellation tokens, context preparation, outgoing call methods, ping)
  from RpcResponderEndpoint and RpcCallerEndpoint respectively.
  RpcPeerEndpoint now composes both mixins with a parity-based message
  filter instead of duplicating ~1400 lines of pipeline code.
  All three endpoint classes reduced to thin shells over shared mixins.

- Tests: 14 peer endpoint tests, 1 generator test for peer codegen

Coverage Stats

545 of 711 new or added lines in 11 files covered. (76.65%)

2 existing lines in 1 file now uncovered.

4291 of 5577 relevant lines covered (76.94%)

9.34 hits per line