func (sub *Subscription) StreamID() int32 {
	return sub.streamID
}
StreamID returns Stream identity for scoping within the channel media address.
package aeron
import (
	"github.com/lirm/aeron-go/aeron/atomic"
	"github.com/lirm/aeron-go/aeron/logbuffer/term"
)
type Subscription struct {
	conductor       *ClientConductor
	channel         string
	roundRobinIndex int
	registrationID  int64
	streamID        int32
	images *ImageList
	isClosed atomic.Bool
}
func NewSubscription(conductor *ClientConductor, channel string, registrationID int64, streamID int32) *Subscription {
	sub := new(Subscription)
	sub.images = NewImageList()
	sub.conductor = conductor
	sub.channel = channel
	sub.registrationID = registrationID
	sub.streamID = streamID
	sub.roundRobinIndex = 0
	sub.isClosed.Set(false)
	return sub
}
func (sub *Subscription) Channel() string {
	return sub.channel
}