Skip to content

Commit 45df46c

Browse files
committed
exported SeparatePluginHandlers
1 parent 86facd9 commit 45df46c

File tree

3 files changed

+6
-6
lines changed

3 files changed

+6
-6
lines changed

Diff for: rpc/core/client.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -206,7 +206,7 @@ func (c *Client) Abort() {
206206

207207
// Use plugin handlers.
208208
func (c *Client) Use(handler ...PluginHandler) *Client {
209-
invokeHandlers, ioHandlers := separatePluginHandlers(handler)
209+
invokeHandlers, ioHandlers := SeparatePluginHandlers(handler)
210210
if len(invokeHandlers) > 0 {
211211
c.invokeManager.Use(invokeHandlers...)
212212
}
@@ -218,7 +218,7 @@ func (c *Client) Use(handler ...PluginHandler) *Client {
218218

219219
// Unuse plugin handlers.
220220
func (c *Client) Unuse(handler ...PluginHandler) *Client {
221-
invokeHandlers, ioHandlers := separatePluginHandlers(handler)
221+
invokeHandlers, ioHandlers := SeparatePluginHandlers(handler)
222222
if len(invokeHandlers) > 0 {
223223
c.invokeManager.Unuse(invokeHandlers...)
224224
}

Diff for: rpc/core/plugin_manager.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
| |
77
| rpc/core/plugin_manager.go |
88
| |
9-
| LastModified: May 12, 2021 |
9+
| LastModified: May 19, 2021 |
1010
| Author: Ma Bingyao <[email protected]> |
1111
| |
1212
\*________________________________________________________*/
@@ -38,7 +38,7 @@ type ioPlugin interface {
3838
Handler(ctx context.Context, request []byte, next NextIOHandler) (response []byte, err error)
3939
}
4040

41-
func separatePluginHandlers(handlers []PluginHandler) (invokeHandlers []PluginHandler, ioHandlers []PluginHandler) {
41+
func SeparatePluginHandlers(handlers []PluginHandler) (invokeHandlers []PluginHandler, ioHandlers []PluginHandler) {
4242
for _, handler := range handlers {
4343
switch handler := handler.(type) {
4444
case InvokeHandler:

Diff for: rpc/core/service.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -183,7 +183,7 @@ func (s *Service) Execute(ctx context.Context, name string, args []interface{})
183183

184184
// Use plugin handlers.
185185
func (s *Service) Use(handler ...PluginHandler) *Service {
186-
invokeHandlers, ioHandler := separatePluginHandlers(handler)
186+
invokeHandlers, ioHandler := SeparatePluginHandlers(handler)
187187
if len(invokeHandlers) > 0 {
188188
s.invokeManager.Use(invokeHandlers...)
189189
}
@@ -195,7 +195,7 @@ func (s *Service) Use(handler ...PluginHandler) *Service {
195195

196196
// Unuse plugin handlers.
197197
func (s *Service) Unuse(handler ...PluginHandler) *Service {
198-
invokeHandlers, ioHandler := separatePluginHandlers(handler)
198+
invokeHandlers, ioHandler := SeparatePluginHandlers(handler)
199199
if len(invokeHandlers) > 0 {
200200
s.invokeManager.Unuse(invokeHandlers...)
201201
}

0 commit comments

Comments
 (0)