Struct streamer

livelog/memory.go:27–31

var ErrStreamNotFound = errors.New("stream: not found")

type streamer struct {
	sync.Mutex

	streams map[int64]*stream
}

// New returns a new in-memory log streamer.
func NewMemory() LogStream {