Method
PredictStream
(_ context.Context, _ *pb.PredictOptions, fn func(reply *pb.Reply), _ ...ggrpc.CallOption)
Source from the content-addressed store, hash-verified
| 66 | } |
| 67 | |
| 68 | func (f *fakeGRPCBackend) PredictStream(_ context.Context, _ *pb.PredictOptions, fn func(reply *pb.Reply), _ ...ggrpc.CallOption) error { |
| 69 | for _, r := range f.streamReplies { |
| 70 | fn(r) |
| 71 | } |
| 72 | return f.streamErr |
| 73 | } |
| 74 | |
| 75 | func (f *fakeGRPCBackend) Embeddings(_ context.Context, _ *pb.PredictOptions, _ ...ggrpc.CallOption) (*pb.EmbeddingResult, error) { |
| 76 | return &pb.EmbeddingResult{}, nil |
Callers
nothing calls this directly
Tested by
no test coverage detected