[RATIS-1114] Change NettyServerStreamRpc to use only one ConcurrentMap

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Component/s: Streaming
• Assignee: Tsz-wo Sze
• Reporter: Tsz-wo Sze
• Created: 28/Oct/20 18:16
• Updated: 28/Oct/20 23:58
• Resolved: 28/Oct/20 23:58

Description

  private final ConcurrentMap<Long, CompletableFuture<DataStream>> streams = new ConcurrentHashMap<>();
  private final ConcurrentMap<Long, List<DataStreamOutput>> peersStreamOutput = new ConcurrentHashMap<>();

The two ConcurrentMaps above should be merged.

Issue Links

• links to: GitHub Pull Request #236