Lines Matching defs:streams
493 streams := make(map[uint32]*serverResponse)
494 streams[id] = res
572 sr, ok := streams[f.FrameHeader.StreamID]
585 if streamEnded(res, streams, sr) {
598 streams[sr.streamID] = sr
600 sr, ok := streams[f.FrameHeader.StreamID]
606 if streamEnded(res, streams, sr) {
611 sr, ok := streams[f.FrameHeader.StreamID]
616 if streamEnded(res, streams, sr) {
639 func streamEnded(mainSr *serverResponse, streams map[uint32]*serverResponse, sr *serverResponse) bool {
640 delete(streams, sr.streamID)
644 return len(streams) == 0