func (driver *Proxy) RemoveSubscription(registrationID int64) {
	correlationID := driver.toDriverCommandBuffer.NextCorrelationID()
	logger.Debugf("driver.RemoveSubscription: correlationId=%d (subId=%d)", correlationID, registrationID)
	filler := func(buffer *atomic.Buffer, length *int) int32 {
		var message command.RemoveMessage
		message.Wrap(buffer, 0)
		message.ClientID.Set(driver.clientID)
		message.CorrelationID.Set(correlationID)
		message.RegistrationID.Set(registrationID)
		*length = message.Size()
		return command.RemoveSubscription
	}
	driver.writeCommandToDriver(filler)
}
RemoveSubscription sends driver command to remove subscription
package driver
import (
	"github.com/lirm/aeron-go/aeron/atomic"
	"github.com/lirm/aeron-go/aeron/command"
	rb "github.com/lirm/aeron-go/aeron/ringbuffer"
)
type Proxy struct {
	toDriverCommandBuffer *rb.ManyToOne
	clientID              int64
}
func (driver *Proxy) Init(buffer *rb.ManyToOne) *Proxy {
	driver.toDriverCommandBuffer = buffer
	driver.clientID = driver.toDriverCommandBuffer.NextCorrelationID()
	logger.Infof("aeron clientID:%d", driver.clientID)
	return driver
}
func (driver *Proxy) ClientID() int64 {
	return driver.clientID
}
func (driver *Proxy) TimeOfLastDriverKeepalive() int64 {
	return driver.toDriverCommandBuffer.ConsumerHeartbeatTime()
}
func (driver *Proxy) NextCorrelationID() int64 {
	return driver.toDriverCommandBuffer.NextCorrelationID()
}
func (driver *Proxy) AddSubscription(channel string, streamID int32) int64 {
	correlationID := driver.toDriverCommandBuffer.NextCorrelationID()
	logger.Debugf("driver.AddSubscription: correlationId=%d", correlationID)
	filler := func(buffer *atomic.Buffer, length *int) int32 {
		var message command.SubscriptionMessage
		message.Wrap(buffer, 0)
		message.ClientID.Set(driver.clientID)
		message.CorrelationID.Set(correlationID)
		message.RegistrationCorrelationID.Set(-1)
		message.StreamID.Set(streamID)
		message.Channel.Set(channel)
		*length = message.Size()
		return command.AddSubscription
	}
	driver.writeCommandToDriver(filler)
	return correlationID
}