|
@@ -146,9 +146,10 @@ func (sws *serverWatchStream) sendLoop() {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
err := sws.gRPCStream.Send(&pb.WatchResponse{
|
|
err := sws.gRPCStream.Send(&pb.WatchResponse{
|
|
|
- Header: sws.newResponseHeader(wresp.Revision),
|
|
|
|
|
- WatchId: int64(wresp.WatchID),
|
|
|
|
|
- Events: events,
|
|
|
|
|
|
|
+ Header: sws.newResponseHeader(wresp.Revision),
|
|
|
|
|
+ WatchId: int64(wresp.WatchID),
|
|
|
|
|
+ Events: events,
|
|
|
|
|
+ Compacted: wresp.Compacted,
|
|
|
})
|
|
})
|
|
|
storage.ReportEventReceived()
|
|
storage.ReportEventReceived()
|
|
|
if err != nil {
|
|
if err != nil {
|