| 226 | func (p *blockingProvider) MaxTokens() int { return 0 } |
| 227 | |
| 228 | type blockingStream struct { |
| 229 | done <-chan struct{} |
| 230 | err func() error |
| 231 | } |
| 232 | |
| 233 | func (s *blockingStream) Recv() (chat.MessageStreamResponse, error) { |
| 234 | // Block until the parent context is cancelled. On cancellation |
nothing calls this directly
no outgoing calls
no test coverage detected