ChainStreamInterceptor returns a ServerOption that specifies the chained interceptor for streaming RPCs. The first interceptor will be the outer most, while the last interceptor will be the inner most wrapper around the real call. All stream interceptors added by this method will be chained.
(interceptors ...StreamServerInterceptor)
| 517 | // while the last interceptor will be the inner most wrapper around the real call. |
| 518 | // All stream interceptors added by this method will be chained. |
| 519 | func ChainStreamInterceptor(interceptors ...StreamServerInterceptor) ServerOption { |
| 520 | return newFuncServerOption(func(o *serverOptions) { |
| 521 | o.chainStreamInts = append(o.chainStreamInts, interceptors...) |
| 522 | }) |
| 523 | } |
| 524 | |
| 525 | // InTapHandle returns a ServerOption that sets the tap handle for all the server |
| 526 | // transport to be created. Only one can be installed. |