remove unused method
Signed-off-by: Davanum Srinivas <davanum@gmail.com>
This commit is contained in:
parent
cbb7c28f19
commit
3ee62de2bf
@ -164,16 +164,6 @@ func (h *httpStreamHandler) monitorStreamPair(p *httpStreamPair, timeout <-chan
|
|||||||
h.removeStreamPair(p.requestID)
|
h.removeStreamPair(p.requestID)
|
||||||
}
|
}
|
||||||
|
|
||||||
// hasStreamPair returns a bool indicating if a stream pair for requestID
|
|
||||||
// exists.
|
|
||||||
func (h *httpStreamHandler) hasStreamPair(requestID string) bool {
|
|
||||||
h.streamPairsLock.RLock()
|
|
||||||
defer h.streamPairsLock.RUnlock()
|
|
||||||
|
|
||||||
_, ok := h.streamPairs[requestID]
|
|
||||||
return ok
|
|
||||||
}
|
|
||||||
|
|
||||||
// removeStreamPair removes the stream pair identified by requestID from streamPairs.
|
// removeStreamPair removes the stream pair identified by requestID from streamPairs.
|
||||||
func (h *httpStreamHandler) removeStreamPair(requestID string) {
|
func (h *httpStreamHandler) removeStreamPair(requestID string) {
|
||||||
h.streamPairsLock.Lock()
|
h.streamPairsLock.Lock()
|
||||||
|
Loading…
Reference in New Issue
Block a user