Method loadStream

server/streamer/streamer.go:114–120

(id StreamID)

}

func (m *Streamer) loadStream(id StreamID) (*stream, bool) {
	strm, ok := m.streams.Load(id)
	if !ok {
		return nil, false
	}
	return strm.(*stream), true
}

type syncStreamIDGenerator struct {
	current uint64