code: func New(graceTime time.Duration) *Streamer {
  	return &Streamer{
  		graceTime: graceTime,
  		streams:   sync.Map{},
  		idGen:     new(syncStreamIDGenerator),
  	}
  }
docs: // New creates a Streamer with the specified grace time which limits the duration of memory consumption by a stopped stream.