|
@@ -11,8 +11,8 @@ import (
|
|
|
|
|
|
|
|
// ServSubscribeBuffer -- буферизованная подписка (на случай временного отключения клиента)
|
|
// ServSubscribeBuffer -- буферизованная подписка (на случай временного отключения клиента)
|
|
|
type ServSubscribeBuffer struct {
|
|
type ServSubscribeBuffer struct {
|
|
|
- serv types.IService
|
|
|
|
|
- dictTopic types.IDictTopic
|
|
|
|
|
|
|
+ serv types.IService
|
|
|
|
|
+ dictTopic types.IDictTopic
|
|
|
dictProxyBuffer types.IDictClientProxyBuffer
|
|
dictProxyBuffer types.IDictClientProxyBuffer
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -22,8 +22,8 @@ func NewServSubscribeBuffer(serv types.IService) (*ServSubscribeBuffer, error) {
|
|
|
return nil, fmt.Errorf("NewServSubscribeBuffer(): IService==nil")
|
|
return nil, fmt.Errorf("NewServSubscribeBuffer(): IService==nil")
|
|
|
}
|
|
}
|
|
|
sf := &ServSubscribeBuffer{
|
|
sf := &ServSubscribeBuffer{
|
|
|
- serv: serv,
|
|
|
|
|
- dictTopic: serv.DictTopic(),
|
|
|
|
|
|
|
+ serv: serv,
|
|
|
|
|
+ dictTopic: serv.DictTopic(),
|
|
|
dictProxyBuffer: serv.DictClientProxyBuffer(),
|
|
dictProxyBuffer: serv.DictClientProxyBuffer(),
|
|
|
}
|
|
}
|
|
|
return sf, nil
|
|
return sf, nil
|