Skip to content

Commit 09fb119

Browse files
authored
support channel notification (#44)
- Support channel notification decoding status #42 - remove merge data feature and do not cache the original data #43 closes #42 #43
1 parent 3df4c08 commit 09fb119

File tree

6 files changed

+925
-483
lines changed

6 files changed

+925
-483
lines changed

pkg/codes/yomo.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,5 +23,9 @@ type YomoCodec interface {
2323

2424
func NewCodec(observe string) YomoCodec {
2525
//return NewCollectingCodec(observe)
26+
return NewMergingCodec(packetutils.KeyOf(observe))
27+
}
28+
29+
func NewCodecWithInform(observe string) (YomoCodec, <-chan bool) {
2630
return NewStreamingCodec(packetutils.KeyOf(observe))
2731
}

0 commit comments

Comments
 (0)