Add Stream.IsCompressed utility function

Signed-off-by: R.I.Pienaar <[email protected]>

streams.go

@@ -864,6 +864,11 @@ func (s *Stream) IsMQTTState() bool {
 	return IsMQTTStateStream(s.Name())
 }
 
+// IsCompressed determines if a stream is compressed
+func (s *Stream) IsCompressed() bool {
+	return s.Compression() != api.NoCompression
+}
+
 // ContainedSubjects queries the stream for the subjects it holds with optional filter
 func (s *Stream) ContainedSubjects(filter ...string) (map[string]uint64, error) {
 	return s.mgr.StreamContainedSubjects(s.Name(), filter...)

streams_test.go

@@ -1015,6 +1015,25 @@ func TestStream_ContainedSubjects(t *testing.T) {
 	// }
 }
 
+func TestStream_Compression(t *testing.T) {
+	srv, nc, mgr := startJSServer(t)
+	defer srv.Shutdown()
+	defer nc.Flush()
+
+	s, err := mgr.NewStream("f1", jsm.Subjects("test.*"), jsm.FileStorage(), jsm.Compression(api.S2Compression))
+	checkErr(t, err, "create failed")
+
+	nfo, err := s.Information()
+	checkErr(t, err, "info failed")
+
+	if nfo.Config.Compression != api.S2Compression {
+		t.Fatalf("s2 compression was not set")
+	}
+
+	if !s.IsCompressed() {
+		t.Fatalf("s2 compression was not reported correctly")
+	}
+}
 func TestStream_DetectGaps(t *testing.T) {
 	srv, nc, mgr := startJSServer(t)
 	defer srv.Shutdown()