Method readStreamId

core/stream.go:65–78

()

}

func (dec *Decoder) readStreamId() (*model.StreamId, error) {
	ms, _, err := dec.readLength()
	if err != nil {
		return nil, err
	}
	seq, _, err := dec.readLength()
	if err != nil {
		return nil, err
	}
	return &model.StreamId{
		Ms:       ms,
		Sequence: seq,
	}, nil
}

// readStreamEntries read entries
func (dec *Decoder) readStreamEntries() ([]*model.StreamEntry, error) {