mirror of https://github.com/status-im/go-waku.git
27 lines
391 B
Go
27 lines
391 B
Go
|
package node
|
||
|
|
|
||
|
|
import (
|
||
|
|
"sync"
|
||
|
|
|
||
|
|
"github.com/status-im/go-waku/waku/common"
|
||
|
|
)
|
||
|
|
|
||
|
|
type Subscription struct {
|
||
|
|
C chan *common.Envelope
|
||
|
|
closed bool
|
||
|
|
mutex sync.Mutex
|
||
|
|
quit chan struct{}
|
||
|
|
}
|
||
|
|
|
||
|
|
func (subs *Subscription) Unsubscribe() {
|
||
|
|
if !subs.closed {
|
||
|
|
close(subs.quit)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
func (subs *Subscription) IsClosed() bool {
|
||
|
|
subs.mutex.Lock()
|
||
|
|
defer subs.mutex.Unlock()
|
||
|
|
return subs.closed
|
||
|
|
}
|