MCPcopy Create free account
hub / github.com/chainreactors/EvilProxy / InterceptStreamChunk

Method InterceptStreamChunk

sdk/pluginapi/types.go:939–939  ·  view source on GitHub ↗
(context.Context, StreamChunkInterceptRequest)

Source from the content-addressed store, hash-verified

937// StreamChunkInterceptor rewrites successful stream chunks before downstream delivery.
938type StreamChunkInterceptor interface {
939 InterceptStreamChunk(context.Context, StreamChunkInterceptRequest) (StreamChunkInterceptResponse, error)
940}
941
942// StreamChunkHeaderInitIndex marks the header-only stream initialization interceptor call.

Callers 7

TestHostApplyConfigDispatchesInterceptorRPCMethodsFunction · 0.65
TestInterceptorHelpersReturnErrorsWhenCallbackMissingFunction · 0.65
callStreamChunkInterceptorMethod · 0.65
TestResponseInterceptorsChainAndStreamHistoryFunction · 0.65
TestStreamInterceptorsDropChunkStopsChainFunction · 0.65
TestInterceptorsDoNotMutateInputsFunction · 0.65
CallMethod · 0.65

Implementers 8

Hostinternal/pluginhost/host.go
rpcPluginAdapterinternal/pluginhost/rpc_client.go
responseInterceptorFuncinternal/pluginhost/test_helpers_test.
modelExecutionSkipHostsdk/api/handlers/model_execution_test.
handlerModelRouterTestHostsdk/api/handlers/handlers_model_router
handlerDirectExecutorInterceptorHostsdk/api/handlers/handlers_model_router
handlerInterceptorTestHostsdk/api/handlers/handlers_interceptors
compileTimePluginsdk/pluginapi/types_test.go

Calls

no outgoing calls

Tested by 6

TestHostApplyConfigDispatchesInterceptorRPCMethodsFunction · 0.52
TestInterceptorHelpersReturnErrorsWhenCallbackMissingFunction · 0.52
TestResponseInterceptorsChainAndStreamHistoryFunction · 0.52
TestStreamInterceptorsDropChunkStopsChainFunction · 0.52
TestInterceptorsDoNotMutateInputsFunction · 0.52
CallMethod · 0.52