From fb2436af182601717084497403a722225184f39f Mon Sep 17 00:00:00 2001 From: Will Browne Date: Wed, 17 Nov 2021 11:33:00 +0000 Subject: [PATCH] fix stream handler funcs (#41800) --- pkg/plugins/manager/manager.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/pkg/plugins/manager/manager.go b/pkg/plugins/manager/manager.go index 9bb490f6c66..991b7474362 100644 --- a/pkg/plugins/manager/manager.go +++ b/pkg/plugins/manager/manager.go @@ -465,8 +465,8 @@ func (m *PluginManager) CheckHealth(ctx context.Context, req *backend.CheckHealt } func (m *PluginManager) SubscribeStream(ctx context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error) { - plugin := m.Plugin(req.PluginContext.PluginID) - if plugin == nil { + plugin, exists := m.plugin(req.PluginContext.PluginID) + if !exists { return nil, backendplugin.ErrPluginNotRegistered } @@ -474,8 +474,8 @@ func (m *PluginManager) SubscribeStream(ctx context.Context, req *backend.Subscr } func (m *PluginManager) PublishStream(ctx context.Context, req *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error) { - plugin := m.Plugin(req.PluginContext.PluginID) - if plugin == nil { + plugin, exists := m.plugin(req.PluginContext.PluginID) + if !exists { return nil, backendplugin.ErrPluginNotRegistered } @@ -483,8 +483,8 @@ func (m *PluginManager) PublishStream(ctx context.Context, req *backend.PublishS } func (m *PluginManager) RunStream(ctx context.Context, req *backend.RunStreamRequest, sender *backend.StreamSender) error { - plugin := m.Plugin(req.PluginContext.PluginID) - if plugin == nil { + plugin, exists := m.plugin(req.PluginContext.PluginID) + if !exists { return backendplugin.ErrPluginNotRegistered }