feat: use single gateway streamer for CompositeGateway

[girishc13]

Goals:

• resolves feat: use single GatewayStreamer object for all gateways in the CompositeGateway #5592

[codecov]

Codecov Report

Merging #5598 (ee87a8f) into master (e5b203e) will increase coverage by 1.47%.
The diff coverage is 100.00%.

@@            Coverage Diff             @@
##           master    #5598      +/-   ##
==========================================
+ Coverage   86.52%   87.99%   +1.47%     
==========================================
  Files         124      124              
  Lines       10069    10070       +1     
==========================================
+ Hits         8712     8861     +149     
+ Misses       1357     1209     -148     

Flag	Coverage Δ
jina	87.99% <100.00%> (+1.47%)	⬆️

Flags with carried forward coverage won't be shown. Click here to find out more.

Impacted Files	Coverage Δ
jina/serve/runtimes/gateway/composite/gateway.py	100.00% <100.00%> (ø)
jina/orchestrate/deployments/__init__.py	89.77% <0.00%> (-0.32%)	⬇️
jina/orchestrate/flow/base.py	90.08% <0.00%> (+0.36%)	⬆️
jina/serve/networking.py	90.45% <0.00%> (+1.23%)	⬆️
jina/helper.py	80.93% <0.00%> (+1.28%)	⬆️
...ina/serve/runtimes/gateway/graph/topology_graph.py	99.48% <0.00%> (+1.54%)	⬆️
jina/serve/streamer.py	94.68% <0.00%> (+2.12%)	⬆️
jina/serve/runtimes/worker/__init__.py	95.74% <0.00%> (+2.12%)	⬆️
jina/clients/base/http.py	95.83% <0.00%> (+2.77%)	⬆️
jina/serve/runtimes/gateway/http/app.py	97.81% <0.00%> (+2.91%)	⬆️
... and 6 more

Help us with your feedback. Take ten seconds to tell us how you rate us. Have a feature suggestion? Share it here.

[JoanFM]

make sure the close method is safe

[alaeddine-13]

make sure the close method is safe

I believe it's fine without a lock. The streamer.close is already called once, when the runtime is shutdown

[girishc13]

The lock is not necessary since the GatewayRuntime handles the gateway.streamer.close() method so there is no need to synchronize between multiple Gateway instances.