diff --git a/baseapp/baseapp.go b/baseapp/baseapp.go index fa7cd9c005f..87ee2e5807e 100644 --- a/baseapp/baseapp.go +++ b/baseapp/baseapp.go @@ -1176,6 +1176,10 @@ func (app *BaseApp) TxEncode(tx sdk.Tx) ([]byte, error) { return app.txEncoder(tx) } +func (app *BaseApp) StreamingManager() storetypes.StreamingManager { + return app.streamingManager +} + // Close is called in start cmd to gracefully cleanup resources. func (app *BaseApp) Close() error { var errs []error diff --git a/server/mock/store.go b/server/mock/store.go index f4cfa42ee9c..222ba39c457 100644 --- a/server/mock/store.go +++ b/server/mock/store.go @@ -30,14 +30,6 @@ func (ms multiStore) CacheWrap() storetypes.CacheWrap { panic("not implemented") } -func (ms multiStore) CacheWrapWithTrace(_ io.Writer, _ storetypes.TraceContext) storetypes.CacheWrap { - panic("not implemented") -} - -func (ms multiStore) CacheWrapWithListeners(_ storetypes.StoreKey, _ []storetypes.MemoryListener) storetypes.CacheWrap { - panic("not implemented") -} - func (ms multiStore) TracingEnabled() bool { panic("not implemented") } @@ -186,10 +178,6 @@ func (kv kvStore) CacheWrapWithTrace(w io.Writer, tc storetypes.TraceContext) st panic("unimplemented") } -func (kv kvStore) CacheWrapWithListeners(_ storetypes.StoreKey, _ []storetypes.MemoryListener) storetypes.CacheWrap { - panic("not implemented") -} - func (kv kvStore) GetStoreType() storetypes.StoreType { panic("not implemented") }